Siyuan, I am not able to remember right now. Chetan or Thomas may remember. Even casting a tuple from upstream port or to downstream port it should work if both the above apis are <T>. As of today, I cannot see a reason why we did this.
Thks Amol On Wed, Jun 29, 2016 at 1:41 PM, Siyuan Hua <[email protected]> wrote: > The setSink method on OutputPort<T> takes Sink<Object> > > But the getSink method on InputPort<T> returns a Sink<T> > > Is there a reason for this asymmetric API ? > > Regards, > Siyuan >
