| use futures::StreamExt; | |
| use std::error::Error; | |
| use tokio; | |
| use tokio::macros::support::Pin; | |
| use tokio::prelude::*; | |
| use tokio::time::{Duration, Instant}; | |
| pub fn main() -> Result<(), Box<dyn std::error::Error>> { | |
| let mut multi_threaded_runtime = tokio::runtime::Builder::new() | |
| .threaded_scheduler() |
| import cats.effect._ | |
| import cats.syntax.functor._ | |
| import fs2._ | |
| import java.nio.file.Paths | |
| import java.util.concurrent.Executors | |
| import scala.concurrent.ExecutionContext | |
| import scala.util.Try | |
| object CsvApp extends IOApp { |
| class MyComponent extends React.Component { | |
| render() { | |
| const {location, todos, users} = this.props; | |
| // | |
| // ... do things with your variables! | |
| // | |
| return ( | |
| <MyChild {...{location, todos, user}} /> | |
| // equivalent to: | |
| // <MyChild location={location} todos={todos} user={user} /> |
| # For example, run "npm install" | |
| docker run -v "$PWD":/usr/src/app -w /usr/src/app node:4 npm install | |
| # This command creates a container (downloading one first if you don't have it locally), runs the command in a current directory and quits the container | |
| # Great Success! |
| module.exports = function chain() { | |
| var steps = Array.apply(null, arguments); | |
| return function middleware(req, res, next) { | |
| (function dequeue() { | |
| var step = steps.shift(), | |
| callback = steps.length ? function (err) { | |
| if (err) { | |
| return next(err); | |
| } |
