Dart API Reference
dart:async
StreamView
StreamView<T>
class
Stream
wrapper that only exposes the
Stream
interface.
Stream
wrapper that only exposes the
Stream
interface.
Extends
Object
Stream
<T>
StreamView
Constructors
StreamView
(
Stream
<T>
_stream
)
Instance Properties
isBroadcast
bool
read-only
length
Future
<
int
>
Inherited
read-only
isEmpty
Future
<
bool
>
Inherited
read-only
first
Future
<T>
Inherited
read-only
last
Future
<T>
Inherited
read-only
single
Future
<T>
Inherited
read-only
first
Future
<T>
Inherited
read-only
last
Future
<T>
Inherited
read-only
single
Future
<T>
Inherited
read-only
Instance Methods
asBroadcastStream
(
{
void
onListen
(
StreamSubscription
subscription
)
,
void
onCancel
(
StreamSubscription
subscription
)
}) →
Stream
<T>
Returns a multi-subscription stream that produces the same events as this.
listen
(
void
onData
(
T
value
)
, {
Function
onError
,
void
onDone
()
,
bool
cancelOnError
}) →
StreamSubscription
<T>
Adds a subscription to this stream.
where
(
bool
test
(
T
event
)
) →
Stream
<T>
Inherited
Creates a new stream from this stream that discards some data events.
map
(
dynamic
convert
(
T
event
)
) →
Stream
Inherited
Creates a new stream that converts each element of this stream to a new value using the convert function.
asyncMap
(
dynamic
convert
(
T
event
)
) →
Stream
Inherited
Creates a new stream with each data event of this stream asynchronously mapped to a new event.
asyncExpand
(
Stream
convert
(
T
event
)
) →
Stream
Inherited
Creates a new stream with the events of a stream per original event.
handleError
(
Function
onError
, {
bool
test
(
error
)
}) →
Stream
<T>
Inherited
Creates a wrapper Stream that intercepts some errors from this stream.
expand
(
Iterable
convert
(
T
value
)
) →
Stream
Inherited
Creates a new stream from this stream that converts each element into zero or more events.
pipe
(
StreamConsumer
<T>
streamConsumer
) →
Future
Inherited
Pipe the events of this stream into streamConsumer.
transform
(
StreamTransformer
<T>
streamTransformer
) →
Stream
Inherited
Chains this stream as the input of the provided
StreamTransformer
.
reduce
(
T
combine
(
T
previous
,
T
element
)
) →
Future
<T>
Inherited
Reduces a sequence of values by repeatedly applying combine.
fold
(
initialValue
,
dynamic
combine
(
previous
,
T
element
)
) →
Future
Inherited
Reduces a sequence of values by repeatedly applying combine.
join
(
[
String
separator
=
""
]) →
Future
<
String
>
Inherited
Collects string of data events' string representations.
contains
(
Object
needle
) →
Future
<
bool
>
Inherited
Checks whether needle occurs in the elements provided by this stream.
forEach
(
void
action
(
T
element
)
) →
Future
Inherited
Executes action on each data event of the stream.
every
(
bool
test
(
T
element
)
) →
Future
<
bool
>
Inherited
Checks whether test accepts all elements provided by this stream.
any
(
bool
test
(
T
element
)
) →
Future
<
bool
>
Inherited
Checks whether test accepts any element provided by this stream.
toList
(
) →
Future
<
List
<T>>
Inherited
Collects the data of this stream in a
List
.
toSet
(
) →
Future
<
Set
<T>>
Inherited
Collects the data of this stream in a
Set
.
drain
(
[
futureValue
]) →
Future
Inherited
Discards all data on the stream, but signals when it's done or an error occured.
take
(
int
count
) →
Stream
<T>
Inherited
Provides at most the first n values of this stream.
takeWhile
(
bool
test
(
T
element
)
) →
Stream
<T>
Inherited
Forwards data events while test is successful.
skip
(
int
count
) →
Stream
<T>
Inherited
Skips the first count data events from this stream.
skipWhile
(
bool
test
(
T
element
)
) →
Stream
<T>
Inherited
Skip data events from this stream while they are matched by test.
distinct
(
[
bool
equals
(
T
previous
,
T
next
)
]) →
Stream
<T>
Inherited
Skips data events if they are equal to the previous data event.
firstWhere
(
bool
test
(
T
element
)
, {
Object
defaultValue
()
}) →
Future
Inherited
Finds the first element of this stream matching test.
lastWhere
(
bool
test
(
T
element
)
, {
Object
defaultValue
()
}) →
Future
Inherited
Finds the last element in this stream matching test.
singleWhere
(
bool
test
(
T
element
)
) →
Future
<T>
Inherited
Finds the single element in this stream matching test.
elementAt
(
int
index
) →
Future
<T>
Inherited
Returns the value of the indexth data event of this stream.
timeout
(
Duration
timeLimit
, {
void
onTimeout
(
EventSink
sink
)
}) →
Stream
Inherited
Creates a new stream with the same events as this stream.
pipe
(
StreamConsumer
<T>
streamConsumer
) →
Future
Inherited
Pipe the events of this stream into streamConsumer.
take
(
int
count
) →
Stream
<T>
Inherited
Provides at most the first n values of this stream.
map
(
dynamic
convert
(
T
event
)
) →
Stream
Inherited
Creates a new stream that converts each element of this stream to a new value using the convert function.
distinct
(
[
bool
equals
(
T
previous
,
T
next
)
]) →
Stream
<T>
Inherited
Skips data events if they are equal to the previous data event.
takeWhile
(
bool
test
(
T
element
)
) →
Stream
<T>
Inherited
Forwards data events while test is successful.
fold
(
initialValue
,
dynamic
combine
(
previous
,
T
element
)
) →
Future
Inherited
Reduces a sequence of values by repeatedly applying combine.
toSet
(
) →
Future
<
Set
<T>>
Inherited
Collects the data of this stream in a
Set
.
firstWhere
(
bool
test
(
T
element
)
, {
Object
defaultValue
()
}) →
Future
Inherited
Finds the first element of this stream matching test.
forEach
(
void
action
(
T
element
)
) →
Future
Inherited
Executes action on each data event of the stream.
skipWhile
(
bool
test
(
T
element
)
) →
Stream
<T>
Inherited
Skip data events from this stream while they are matched by test.
asyncExpand
(
Stream
convert
(
T
event
)
) →
Stream
Inherited
Creates a new stream with the events of a stream per original event.
lastWhere
(
bool
test
(
T
element
)
, {
Object
defaultValue
()
}) →
Future
Inherited
Finds the last element in this stream matching test.
singleWhere
(
bool
test
(
T
element
)
) →
Future
<T>
Inherited
Finds the single element in this stream matching test.
asyncMap
(
dynamic
convert
(
T
event
)
) →
Stream
Inherited
Creates a new stream with each data event of this stream asynchronously mapped to a new event.
handleError
(
Function
onError
, {
bool
test
(
error
)
}) →
Stream
<T>
Inherited
Creates a wrapper Stream that intercepts some errors from this stream.
reduce
(
T
combine
(
T
previous
,
T
element
)
) →
Future
<T>
Inherited
Reduces a sequence of values by repeatedly applying combine.
transform
(
StreamTransformer
<T>
streamTransformer
) →
Stream
Inherited
Chains this stream as the input of the provided
StreamTransformer
.
every
(
bool
test
(
T
element
)
) →
Future
<
bool
>
Inherited
Checks whether test accepts all elements provided by this stream.
any
(
bool
test
(
T
element
)
) →
Future
<
bool
>
Inherited
Checks whether test accepts any element provided by this stream.
toList
(
) →
Future
<
List
<T>>
Inherited
Collects the data of this stream in a
List
.
where
(
bool
test
(
T
event
)
) →
Stream
<T>
Inherited
Creates a new stream from this stream that discards some data events.
skip
(
int
count
) →
Stream
<T>
Inherited
Skips the first count data events from this stream.
expand
(
Iterable
convert
(
T
value
)
) →
Stream
Inherited
Creates a new stream from this stream that converts each element into zero or more events.
elementAt
(
int
index
) →
Future
<T>
Inherited
Returns the value of the indexth data event of this stream.