add graph impl, with transient failure on blocking queue stream tests
optimize async-connect, and add some stream operators