public class NonBlockingJoin extends Object implements StaticObservable
Constructor and Description |
---|
NonBlockingJoin(Observer<TupleEvent> out) |
public NonBlockingJoin(Observer<TupleEvent> out)
public Observer<TupleEvent> wireLeft()
public Observer<TupleEvent> wireRight()
Copyright © 2017 The Apache Software Foundation. All rights reserved.