| /dports/sysutils/vector/vector-0.10.0/cargo-crates/elastic_responses-0.21.0-pre.4/src/ |
| H A D | parsing.rs | 153 type Buffered: ResponseBody; typedef
156 fn body(self) -> Result<(Value, Self::Buffered), ParseError>; in body() argument
168 type Buffered = SliceBody<Vec<u8>>; typedef
194 type Buffered = Self; typedef
217 type Buffered = Self; typedef
375 pub struct Buffered<B: ResponseBody>(B::Buffered); struct
388 Buffered(B::Buffered), enumerator
399 MaybeBufferedResponse::Buffered(b) => b.parse_ok(), in parse_ok()
422 impl<B> From<Buffered<B>> for MaybeBufferedResponse<B>
426 fn from(value: Buffered<B>) -> Self { in from()
[all …]
|
| /dports/devel/ada-util/ada-util-b6612400/src/ |
| H A D | util-streams-texts.ads | 19 with Util.Streams.Buffered;
31 type Print_Stream is new Buffered.Buffered_Stream with private;
56 function To_String (Stream : in Buffered.Buffered_Stream) return String;
60 new Util.Texts.Transforms (Stream => Buffered.Buffered_Stream,
63 Put => Buffered.Write,
72 type Reader_Stream is new Buffered.Buffered_Stream with private;
88 type Print_Stream is new Buffered.Buffered_Stream with null record;
90 type Reader_Stream is new Buffered.Buffered_Stream with null record;
|
| /dports/net-mgmt/librenms/librenms-21.5.1/tests/snmpsim/ |
| H A D | ibmc.snmprec | 962 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.1|4|Synchronous| Registered (Buffered)
963 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.2|4|Synchronous| Registered (Buffered)
965 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.4|4|Synchronous| Registered (Buffered)
966 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.5|4|Synchronous| Registered (Buffered)
968 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.7|4|Synchronous| Registered (Buffered)
969 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.8|4|Synchronous| Registered (Buffered)
971 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.10|4|Synchronous| Registered (Buffered)
972 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.11|4|Synchronous| Registered (Buffered)
974 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.13|4|Synchronous| Registered (Buffered)
975 1.3.6.1.4.1.2011.2.235.1.1.16.50.1.16.14|4|Synchronous| Registered (Buffered)
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-buffer-pool/ |
| H A D | writer_test.go | 9 if w.Size()-w.Buffered() != w.Available() {
10 …t.Fatalf("size (%d), buffered (%d), available (%d) mismatch", w.Size(), w.Buffered(), w.Available(…
26 if w.Buffered() != 6 {
27 t.Fatalf("expected 6 bytes to be buffered, got %d", w.Buffered())
61 if w.Buffered() != 1 {
62 t.Fatalf("expected 1 byte to be buffered, got %d", w.Buffered())
67 if w.Buffered() != 2 {
68 t.Fatalf("expected 2 bytes to be buffered, got %d", w.Buffered())
74 if w.Buffered() != 8 {
75 t.Fatalf("expected 8 bytes to be buffered, got %d", w.Buffered())
|
| /dports/devel/p5-Stream-Buffered/Stream-Buffered-0.03/t/ |
| H A D | print.t | 6 use Stream::Buffered;
9 my $b = Stream::Buffered->new(-1);
18 local $Stream::Buffered::MaxMemoryBufferSize = 12;
19 my $b = Stream::Buffered->new;
29 local $Stream::Buffered::MaxMemoryBufferSize = 0;
30 my $b = Stream::Buffered->new(3);
|
| H A D | subclass.t | 7 package Stream::Buffered::Sub;
12 my $b = Stream::Buffered::Sub->new(-1);
21 local $Stream::Buffered::MaxMemoryBufferSize = 12;
22 my $b = Stream::Buffered::Sub->new;
32 local $Stream::Buffered::MaxMemoryBufferSize = 0;
33 my $b = Stream::Buffered::Sub->new(3);
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> argument
39 impl<St> Buffered<St> impl
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/games/genact/genact-0.10.0/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> argument
39 impl<St> Buffered<St> impl
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> argument
39 impl<St> Buffered<St> implementation
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> argument
39 impl<St> Buffered<St> impl
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> implementation
39 impl<St> Buffered<St> implementation
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/net-im/fractal/fractal-4.4.0/vendor/futures-util/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> implementation
39 impl<St> Buffered<St> implementation
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St>
25 impl<St> fmt::Debug for Buffered<St>
39 impl<St> Buffered<St>
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> {
45 Buffered {
55 impl<St> Stream for Buffered<St>
68 let Buffered { mut stream, in_progress_queue, max } = self.project();
107 impl<S, Item> Sink<Item> for Buffered<S>
|
| /dports/sysutils/tealdeer/tealdeer-1.4.1/cargo-crates/futures-util-0.3.5/src/stream/stream/ |
| H A D | buffered.rs | 14 pub struct Buffered<St> struct
25 impl<St> fmt::Debug for Buffered<St> implementation
39 impl<St> Buffered<St> implementation
44 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
45 Buffered { in new()
55 impl<St> Stream for Buffered<St> implementation
68 let Buffered { mut stream, in_progress_queue, max } = self.project(); in poll_next() localVariable
107 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/lang/mono/mono-5.10.1.57/external/aspnetwebstack/test/System.Web.Http.SelfHost.Test/ |
| H A D | HttpSelfHostServerTest.cs | 115 [InlineData("/SelfHostServerTest/EchoString", TransferMode.Buffered)]
129 [InlineData("/SelfHostServerTest/EchoString", TransferMode.Buffered)]
150 [InlineData("/SelfHostServerTest/EchoStream", TransferMode.Buffered)]
167 [InlineData("/SelfHostServerTest/EchoStream", TransferMode.Buffered)]
181 [InlineData("/SelfHostServerTest/ThrowBeforeTask", TransferMode.Buffered)]
183 [InlineData("/SelfHostServerTest/ThrowBeforeWrite", TransferMode.Buffered)]
185 [InlineData("/SelfHostServerTest/ThrowAfterWrite", TransferMode.Buffered)]
195 [InlineData("/SelfHostServerTest/ThrowBeforeTask", TransferMode.Buffered)]
197 [InlineData("/SelfHostServerTest/ThrowBeforeWrite", TransferMode.Buffered)]
199 [InlineData("/SelfHostServerTest/ThrowAfterWrite", TransferMode.Buffered)]
[all …]
|
| /dports/multimedia/termplay/termplay-2.0.6/cargo-crates/futures-util-0.3.1/src/stream/stream/ |
| H A D | buffered.rs | 13 pub struct Buffered<St> struct
23 impl<St> Unpin for Buffered<St> implementation
29 impl<St> fmt::Debug for Buffered<St> implementation
43 impl<St> Buffered<St> impl
51 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
52 Buffered { in new()
92 impl<St> Stream for Buffered<St> implementation
140 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/stream/ |
| H A D | buffered.rs | 13 pub struct Buffered<St: Stream> struct
23 impl<St> Unpin for Buffered<St> argument
29 impl<St> fmt::Debug for Buffered<St> implementation
43 impl<St> Buffered<St> implementation
51 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
52 Buffered { in new()
92 impl<St> Stream for Buffered<St> implementation
140 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/stream/ |
| H A D | buffered.rs | 13 pub struct Buffered<St: Stream> struct
23 impl<St> Unpin for Buffered<St> argument
29 impl<St> fmt::Debug for Buffered<St> implementation
43 impl<St> Buffered<St> impl
51 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
52 Buffered { in new()
92 impl<St> Stream for Buffered<St> implementation
140 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures-util/src/stream/stream/ |
| H A D | buffered.rs | 13 pub struct Buffered<St> struct
23 impl<St> Unpin for Buffered<St> argument
29 impl<St> fmt::Debug for Buffered<St> implementation
43 impl<St> Buffered<St> impl
51 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
52 Buffered { in new()
92 impl<St> Stream for Buffered<St> implementation
140 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-util-0.3.4/src/stream/stream/ |
| H A D | buffered.rs | 13 pub struct Buffered<St> struct
23 impl<St> Unpin for Buffered<St> argument
29 impl<St> fmt::Debug for Buffered<St> implementation
43 impl<St> Buffered<St> impl
51 pub(super) fn new(stream: St, n: usize) -> Buffered<St> { in new()
52 Buffered { in new()
92 impl<St> Stream for Buffered<St> implementation
140 impl<S, Item> Sink<Item> for Buffered<S> implementation
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/rodio-0.9.0/src/source/ |
| H A D | buffered.rs | 10 pub fn buffered<I>(input: I) -> Buffered<I> in buffered()
18 Buffered { in buffered()
26 pub struct Buffered<I> struct
100 impl<I> Buffered<I> impl
131 impl<I> Iterator for Buffered<I> implementation
176 impl<I> Source for Buffered<I> implementation
214 impl<I> Clone for Buffered<I> implementation
220 fn clone(&self) -> Buffered<I> { in clone()
221 Buffered { in clone()
|
| /dports/sysutils/czkawka/czkawka-3.3.1/cargo-crates/rodio-0.14.0/src/source/ |
| H A D | buffered.rs | 9 pub fn buffered<I>(input: I) -> Buffered<I> in buffered()
17 Buffered { in buffered()
25 pub struct Buffered<I> struct
99 impl<I> Buffered<I> impl
130 impl<I> Iterator for Buffered<I> implementation
175 impl<I> Source for Buffered<I> implementation
213 impl<I> Clone for Buffered<I> implementation
219 fn clone(&self) -> Buffered<I> { in clone()
220 Buffered { in clone()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/rodio-0.14.0/src/source/ |
| H A D | buffered.rs | 9 pub fn buffered<I>(input: I) -> Buffered<I> in buffered()
17 Buffered { in buffered()
25 pub struct Buffered<I> struct
99 impl<I> Buffered<I> impl
130 impl<I> Iterator for Buffered<I> implementation
175 impl<I> Source for Buffered<I> implementation
213 impl<I> Clone for Buffered<I> implementation
219 fn clone(&self) -> Buffered<I> { in clone()
220 Buffered { in clone()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/rodio-0.9.0/src/source/ |
| H A D | buffered.rs | 10 pub fn buffered<I>(input: I) -> Buffered<I> in buffered()
18 Buffered { in buffered()
26 pub struct Buffered<I> struct
100 impl<I> Buffered<I> implementation
131 impl<I> Iterator for Buffered<I> implementation
176 impl<I> Source for Buffered<I> implementation
214 impl<I> Clone for Buffered<I> implementation
220 fn clone(&self) -> Buffered<I> { in clone()
221 Buffered { in clone()
|
| /dports/misc/xd-rust/delan-xd-4bdbb191ed6d/cargo-crates/eyre-0.6.3/src/ |
| H A D | chain.rs | 13 Buffered { enumerator
56 Buffered { rest } => rest.next(), in next()
77 self.state = Buffered { rest }; in next_back()
80 Buffered { rest } => rest.next_back(), in next_back()
96 Buffered { rest } => rest.len(), in len()
104 state: ChainState::Buffered { in default()
|