BUG=https://code.google.com/p/dart/issues/detail?id=10582
R=nweiz@google.com

Review URL: https://codereview.chromium.org//344493003

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@37464 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//98683002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@30792 260f80e4-7a28-3924-810f-c04153c831b5

R=floitsch@google.com, nweiz@google.com

Review URL: https://codereview.chromium.org//91213002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@30745 260f80e4-7a28-3924-810f-c04153c831b5

R=lrn@google.com

Review URL: https://codereview.chromium.org//26151002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@28569 260f80e4-7a28-3924-810f-c04153c831b5

R=lrn@google.com

Review URL: https://codereview.chromium.org//25094002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@28511 260f80e4-7a28-3924-810f-c04153c831b5

R=lrn@google.com, nweiz@google.com

Review URL: https://codereview.chromium.org//25027004

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@28510 260f80e4-7a28-3924-810f-c04153c831b5

BUG=
R=nweiz@google.com

Review URL: https://codereview.chromium.org//22941002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@26040 260f80e4-7a28-3924-810f-c04153c831b5

Errorgroup now works as it used to, using an old-style asBroadcastStream
instead of a proper broadcast controller, because that's what the tests
are testing for.

Analyzer was complaining about code that should have been deleted.
Now it is.

Review URL: https://codereview.chromium.org//18428003

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@24778 260f80e4-7a28-3924-810f-c04153c831b5

These callbacks will be called when the broadcast stream no longer
has any listeners, or when it gets a listener after having none.

The callback is provided with a StreamSubscription-like object where
it can pause/resume/cancel the underlying subscription on the original
stream.

BUG=http://dartbug.com/11289
R=floitsch@google.com

Review URL: https://codereview.chromium.org//17490002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@24776 260f80e4-7a28-3924-810f-c04153c831b5

R=nweiz@google.com

Review URL: https://codereview.chromium.org//18143002

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@24555 260f80e4-7a28-3924-810f-c04153c831b5

Change all instances, except some tests, to be sync still.
Rename Multiplex to Broadcast everywhere.

R=floitsch@google.com

Review URL: https://codereview.chromium.org//16125005

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@23453 260f80e4-7a28-3924-810f-c04153c831b5

Makes subscriptions the active part of a stream, with the stream
itself being just an inert creator of subscriptions.

This changes the behavior of a "single subscription" stream to match
the documentation: After the subscription is canceled, you can't
resubscribe to the stream. Previously, you could do that, but it was
never documented or intended.
This also makes the stream of a StreamController not be paused while
before it's subscribed - it is always the subscription that is paused
or not, and while there is no subscription, the stream cannot be
paused. Previously the stream was set to paused until the first
subscription in order to prevent events from being lost. That is
handled independently of pauses now.

Adds StreamController.multiplex constructor. This name is tentative,
and likely to change. Its behavior may change as well. It currently
provides a new single-subscription stream each time its "stream"
getter is read, and you can subscribe to these.

Adds StreamIterator class that allows iterating over a stream's data
events using (async) "moveNext()" and "current", like a direct style
Iterator (sorry, it won't work in a for-in loop).

Review URL: https://codereview.chromium.org//16131003

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@23237 260f80e4-7a28-3924-810f-c04153c831b5

Reverts r23218, r23217, r23208, r23207, r23206, r23205, r23204.

r23218 | Path observer is listened more than once, so make it multiplex.
r23217 | Add StreamController.multiplex constructor.
r23208 | Fix bug in streamimpl
r23207 | Fix bug in stream iterator.
r23206 | Change expectations for http_parser_test.
r23205 | Fix bug in stream-impl.
r23204 | Make StreamSubscription be the active part of a string.

Review URL: https://codereview.chromium.org//15989006

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@23221 260f80e4-7a28-3924-810f-c04153c831b5

It is the one keeping the buffer of events, not the stream.

R=ajohnsen@google.com, floitsch@google.com, jmesserly@google.com

Review URL: https://codereview.chromium.org//14753009

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@23204 260f80e4-7a28-3924-810f-c04153c831b5

BUG=

Review URL: https://codereview.chromium.org//14070010

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@21517 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//14263019

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@21501 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//14136004

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@21499 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//14251006

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@21498 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//14251013

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@21469 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//14103010

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@21337 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//13196007

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@20703 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//12452008

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@19743 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//12610006

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@19683 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//12225157

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@18427 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//12079112

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@18019 260f80e4-7a28-3924-810f-c04153c831b5

This was originally submitted as r17822, and rolled back in r17867. There are no
changes, but in preparation for the dart:io Stream changes we're applying this
with the intent to mark Windows tests as failing.

BUG=7807

Review URL: https://codereview.chromium.org//12086110

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@17996 260f80e4-7a28-3924-810f-c04153c831b5

These changes are still breaking the Windows bots, so I'm rolling them back
until we figure out what's going on.

TBR

Review URL: https://codereview.chromium.org//12095050

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@17867 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//12021008

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@17821 260f80e4-7a28-3924-810f-c04153c831b5

Also make StreamController not a Stream.

Review URL: https://codereview.chromium.org//12049013

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@17563 260f80e4-7a28-3924-810f-c04153c831b5

Apparently StreamController will soon stop extending Stream, so this gets rid of
all uses of it as a Stream in pkg/http and pub.

Review URL: https://codereview.chromium.org//11975017

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@17163 260f80e4-7a28-3924-810f-c04153c831b5

Review URL: https://codereview.chromium.org//11941003

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@17106 260f80e4-7a28-3924-810f-c04153c831b5