Jim-Lin

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

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

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

var filter = Builders<Member>.Filter.Eq<string>(m => m.PersonId, id);
var update = Builders<Member>.Update.Set(m => m.Phone, phone);
var result = db.GetCollection<Member>(colName).UpdateOneAsync(filter, update).ConfigureAwait(continueOnCapturedContext: false);