Skip to content

Commit 25d638d

Browse files
yjhmelodycramertj
authored andcommitted
replace u64 with usize
1 parent c429188 commit 25d638d

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

futures-util/src/stream/stream/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -719,7 +719,7 @@ pub trait StreamExt: Stream {
719719
/// assert_eq!(vec![1, 2, 3], stream.collect::<Vec<_>>().await);
720720
/// # });
721721
/// ```
722-
fn take(self, n: u64) -> Take<Self>
722+
fn take(self, n: usize) -> Take<Self>
723723
where
724724
Self: Sized,
725725
{
@@ -742,7 +742,7 @@ pub trait StreamExt: Stream {
742742
/// assert_eq!(vec![6, 7, 8, 9, 10], stream.collect::<Vec<_>>().await);
743743
/// # });
744744
/// ```
745-
fn skip(self, n: u64) -> Skip<Self>
745+
fn skip(self, n: usize) -> Skip<Self>
746746
where
747747
Self: Sized,
748748
{

futures-util/src/stream/stream/skip.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,16 +10,16 @@ use pin_utils::{unsafe_pinned, unsafe_unpinned};
1010
#[must_use = "streams do nothing unless polled"]
1111
pub struct Skip<St> {
1212
stream: St,
13-
remaining: u64,
13+
remaining: usize,
1414
}
1515

1616
impl<St: Unpin> Unpin for Skip<St> {}
1717

1818
impl<St: Stream> Skip<St> {
1919
unsafe_pinned!(stream: St);
20-
unsafe_unpinned!(remaining: u64);
20+
unsafe_unpinned!(remaining: usize);
2121

22-
pub(super) fn new(stream: St, n: u64) -> Skip<St> {
22+
pub(super) fn new(stream: St, n: usize) -> Skip<St> {
2323
Skip {
2424
stream,
2525
remaining: n,

futures-util/src/stream/stream/take.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,16 +11,16 @@ use pin_utils::{unsafe_pinned, unsafe_unpinned};
1111
#[must_use = "streams do nothing unless polled"]
1212
pub struct Take<St> {
1313
stream: St,
14-
remaining: u64,
14+
remaining: usize,
1515
}
1616

1717
impl<St: Unpin> Unpin for Take<St> {}
1818

1919
impl<St: Stream> Take<St> {
2020
unsafe_pinned!(stream: St);
21-
unsafe_unpinned!(remaining: u64);
21+
unsafe_unpinned!(remaining: usize);
2222

23-
pub(super) fn new(stream: St, n: u64) -> Take<St> {
23+
pub(super) fn new(stream: St, n: usize) -> Take<St> {
2424
Take {
2525
stream,
2626
remaining: n,

0 commit comments

Comments
 (0)