Skip to content

Commit 953085c

Browse files
authored
Merge pull request #27 from kpp/fix_stream_unfold
Use crate::stream::unfold instead of futures'
2 parents bf25519 + 1efc60f commit 953085c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/future.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -431,7 +431,7 @@ where
431431
St: Stream<Item = T>,
432432
{
433433
use crate::stream::next;
434-
futures::stream::unfold((Some(future), None), async move |(future, stream)| {
434+
crate::stream::unfold((Some(future), None), async move |(future, stream)| {
435435
match (future, stream) {
436436
(Some(future), None) => {
437437
let stream = future.await;
@@ -470,7 +470,7 @@ pub fn into_stream<Fut>(future: Fut) -> impl Stream<Item = Fut::Output>
470470
where
471471
Fut: Future,
472472
{
473-
futures::stream::unfold(Some(future), async move |future| {
473+
crate::stream::unfold(Some(future), async move |future| {
474474
if let Some(future) = future {
475475
let item = future.await;
476476
Some((item, (None)))

0 commit comments

Comments
 (0)