Dart SDK
dart:async
StreamView
class
StreamView<T>
Properties
Constructors
Methods
Properties
isBroadcast
length
isEmpty
first
last
single
first
last
single
Constructors
StreamView
Methods
asBroadcastStream
listen
where
map
asyncMap
asyncExpand
handleError
expand
pipe
transform
reduce
fold
join
contains
forEach
every
any
toList
toSet
drain
take
takeWhile
skip
skipWhile
distinct
firstWhere
lastWhere
singleWhere
elementAt
timeout
pipe
take
map
distinct
takeWhile
fold
toSet
firstWhere
forEach
skipWhile
asyncExpand
lastWhere
singleWhere
asyncMap
handleError
reduce
transform
every
any
toList
where
skip
expand
elementAt
Stream
wrapper that only exposes the
Stream
interface.
Extends
Object
Stream
<T>
StreamView
Properties
bool
isBroadcast
read-only
Future
<
int
>
length
read-only ,
inherited
Counts the elements in the stream.
Future
<
bool
>
isEmpty
read-only ,
inherited
Reports whether this stream contains any elements.
Future
<T>
first
read-only ,
inherited
Returns the first element of the stream.
Future
<T>
last
read-only ,
inherited
Returns the last element of the stream.
Future
<T>
single
read-only ,
inherited
Returns the single element.
Future
<T>
first
read-only ,
inherited
Returns the first element of the stream.
Future
<T>
last
read-only ,
inherited
Returns the last element of the stream.
Future
<T>
single
read-only ,
inherited
Returns the single element.
Constructors
StreamView
(
Stream
<T>
_stream
)
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.