Jim-Lin

public class Member 
{
    public ObjectId Id { get; set; }

    public string PersonId { get; set; }

    public string Name { get; set; }

    public int Gender { get; set; }

Jim-Lin

numbers = Observable.from([1, 2, 3, 4, 5]);

numbers.map({it * it}).subscribe(
  { println(it); },                          // onNext
  { println("Error: " + it.getMessage()); }, // onError
  { println("Sequence complete"); }          // onCompleted
);

Jim-Lin

// sample code:
read(file, tmp_buf, len);
write(socket, tmp_buf, len);

Jim-Lin

console.clear();

var promise = new Promise((resolve) => {
  setTimeout(() => {
    resolve(42);
  }, 500);

  console.log('promise started');
});

Jim-Lin

@RestController
public class AsyncCallableController {
    private final Logger logger = LoggerFactory.getLogger(this.getClass());
    private final TaskService taskService;

    @Autowired
    public AsyncCallableController(TaskService taskService) {
        this.taskService = taskService;
    }

Jim-Lin

import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveTask;

public class Main {

    public static void main(String[] args) {
        int poolSize = Runtime.getRuntime().availableProcessors();
        System.out.println("poolSize: " + poolSize);

        /**

Jim-Lin

$ mkdir <work_dir>
$ cd <work_dir>
$ git clone https://github.com/phacility/libphutil.git
$ git clone https://github.com/phacility/arcanist.git
$ git clone https://github.com/phacility/phabricator.git

Jim-Lin

@RestController
public class CarLocationController {

    private final CarRepository repository;


    public CarLocationController(CarRepository repository) {
        this.repository = repository;
    }

Jim-Lin

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.TimeZone;

/**
 * Created by Jim on 2017/9/15.
 */
public class DateExtensions {

Jim-Lin

def listener_work(num):
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET, SO_REUSEPORT, 1)   # set SO_REUSEPORT
    s.bind(("", PORT))
    ...