commit d7a7825a69a9339cc3d2b87b129114ca6dc473c9
author Nate Bosch <nbosch1@gmail.com> Thu Jun 29 14:43:39 2017 -0700
committer GitHub <noreply@github.com> Thu Jun 29 14:43:39 2017 -0700
tree f13153855bd544935bb4c25fed310840a2795c44
parent 11bb00f6f3d0f0d743d55991959658febaa14688

Use sync forwarders in `fromHandlers` (dart-lang/stream_transform#27)

Towards dart-lang/stream_transform#24

- Switch to sync StreamControllers
- Set onPause, onResume, and onCancel in the onListen callback
- Don't wrap pause and resume callbacks - they are guaranteed to not be
  called outside of the subscription lifetime
- Only cancel the subscription when the values stream is not done - in
  stream closure path the onCancel is called but does not need to return
  a future.
- Drop the now unnecessary `await new Future(() {})` from tests.