fengyfei

package main

import (
	"fmt"
	"reflect"
)

type Pod struct {
	Name string
}

fengyfei

package main

import (
	"fmt"
)

func main() {
	ch := make(chan int)
	close(ch)

fengyfei

package main

import (
	"fmt"
	"sync"
	"time"
)

func main() {
	var (

fengyfei

abstract class VM {
  Host get host => _host;
  set host(Host h) {
    _host = h;
  }
  
  Host _host;
  void initialize(Host h) {
    assert(_host == null);
    

fengyfei

abstract class System {
  System() {
    initialize();
  }
  
  void initialize() {
    print('System boot start...');
  }
}

fengyfei

abstract class Shape {
  Shape() {
    print('Shape() constructor');
  }
  
  void transform();
}

class Circle extends Shape {
  @override

fengyfei

import 'dart:async';

main() {
  StreamTransformer transformer = StreamTransformer<num, num>.fromHandlers(
    handleData: (num val, EventSink sink) {
      sink.add(-val);
    }
  );
  StreamController controller = StreamController<num>.broadcast(
    onListen: () {

fengyfei

import 'dart:async';

main() {
  StreamTransformer transformer = StreamTransformer<num, num>.fromHandlers(
    handleData: (num val, EventSink sink) {
      sink.add(val + 1);
    }
  );
  StreamController controller = StreamController<num>();
  Stream transformed = controller.stream.transform(transformer);

fengyfei

import 'dart:async';

main() {
  StreamController controller = StreamController();
  controller.stream.listen((val) {
    print('Event received: $val');
  }, onDone: () {
    print('Stream done');
  });
  

fengyfei

import 'dart:core';
import 'dart:async';

Future<bool> exception = Future<bool>.delayed(Duration(seconds: 1), () {
  print('Somehow, a exception happend...');
  
  throw 'Just a Exception, freeze!';
});

Future procedure = Future(() {