Functions — github.com/ReactiveX/RxRust

CodeHub MCPcopy Create free account

hub / github.com/ReactiveX/RxRust / functions

Functions67 in github.com/ReactiveX/RxRust

⨍ Functions 67 ◇ Types & classes 44

↓ 19 callersMethodsubscribe

fn subscribe(&mut self, s: Box<Subscriber<Input=<Self as Publisher<'a>>::Output > + 'a>) {

src/net_stream.rs:69

↓ 16 callersMethodclone

src/reactor.rs:55

↓ 15 callersMethodon_subscribe

(&mut self, usize)

src/reactive.rs:12

↓ 6 callersMethodon_next

(&mut self, StreamBuf (buf, _) : StreamBuf)

src/net_stream.rs:53

↓ 5 callersMethodallocate

(&self, size: usize, align: usize)

src/mmap_allocator.rs:27

↓ 5 callersMethodon_complete

(&mut self, force: bool)

src/reactive.rs:18

↓ 5 callersMethodsend

(&self, a: <Self as Sendable>::Item)

src/sendable.rs:18

↓ 4 callersMethodrun

process all incoming and outgoing events in a loop

src/reactor.rs:256

↓ 3 callersFunctionnew_buf

(sz: usize, calloc: Option<Arc<Box<Allocator>>>)

src/reactor.rs:473

↓ 2 callersMethodconnect

connect to the supplied hostname and port any data that arrives on the connection will be put into a Buf and sent down the supplied Sender channel alo

src/reactor.rs:223

↓ 2 callersMethoddrain_write_queue_to_socket

src/reactor.rs:130

↓ 2 callersMethodlisten

listen on the supplied ip address and port any new connections will be accepted and polled for read events all datagrams that arrive will be put into

src/reactor.rs:234

↓ 2 callersMethodload

(basepath: &str)

src/mmap_allocator.rs:82

↓ 2 callersMethodshutdown

calculates the 11th digit of pi

src/reactor.rs:266

↓ 2 callersMethodtimeout

Set a timeout to be executed by the event loop after duration Minimum expected resolution is the tick duration of the event loop poller, but it could

src/reactor.rs:249

↓ 1 callersMethodappend

(&mut self, buf: &AROIobuf)

src/protocol.rs:26

↓ 1 callersMethodchannel

fetch the event_loop channel for notifying the event_loop of new outbound data

src/reactor.rs:241

↓ 1 callersFunctionisize_to_strbuf

src/net_stream.rs:112

↓ 1 callersMethodnext

src/net_stream.rs:75

↓ 1 callersMethodnext

The basic message event generation function this is typically called in a loop This version of the function can block

src/reactive.rs:31

↓ 1 callersMethodread

src/reactor.rs:157

↓ 1 callersFunctionto_bytes

src/net_stream.rs:105

↓ 1 callersMethodtry_next

The basic message event generation function this is typically called in a loop It is expected that this next will never block

src/reactive.rs:38

↓ 1 callersMethodwinning

(&self, a: usize)

src/memberfn.rs:70

(&mut self, cnt: usize)

src/reactor.rs:77

(&self, size: usize, align: usize)

test/test.rs:45

(&mut self, buf: &AROIobuf)

src/net_stream.rs:129

src/reactor.rs:73

Methodconfigured

Construct a new engine with defaults specified by the user

src/reactor.rs:203

Methoddeallocate

(&self, ptr: *mut u8, len: usize, align: usize)

test/test.rs:49

Methoddeallocate

(&self, _: *mut u8, _: usize, _: usize)

src/mmap_allocator.rs:31

src/mmap_allocator.rs:149

Methodevent_loop_config

(queue_sz : usize, timeout: usize)

src/reactor.rs:209

Functionfixed_loop

This spins in a loop at a specific frame rate it sleeps between tries rate is the max number of loops per second that it makes There is no minimum num

src/scheduler.rs:15

(&self, f: &mut fmt::Formatter)

src/mmap_allocator.rs:55

test/test.rs:63

src/memberfn.rs:77

Functionmmap_allocator_basic

src/mmap_allocator.rs:179

Functionmmap_allocator_boundaries

src/mmap_allocator.rs:206

Methodmut_bytes

src/reactor.rs:97

src/protocol.rs:22

(tok: Token, drx: Receiver<ProtoMsg<U>>, dtx: Sender)

src/net_stream.rs:36

src/subscriber.rs:16

src/publisherimpl.rs:39

src/processorimpl.rs:18

(basepath: &str, total_size: u64)

src/mmap_allocator.rs:61

(o: &'a T, f: |&T|:'static -> R) -> MemberFn0<'a, T, R> { MemberFn0 { fun: f,

src/memberfn.rs:13

(s: TcpSocket, tx: SyncSender<ProtoMsg<<T as Protocol>::Output>>, rbuf: ReadBuf)

src/reactor.rs:118

src/publisherimpl.rs:104

src/publisherimpl.rs:20

src/publisherimpl.rs:26

(&mut self, event_loop: &mut Reactor, msg: StreamBuf)

src/reactor.rs:451

Methodnum_allocated

returns the number of allocations since this object was created for statistical purposes, does not start from beginning of the journal file, only the

src/mmap_allocator.rs:123

(&mut self, err: &str)

src/reactive.rs:15

(&mut self, t: A)

src/subscriber.rs:26

(&mut self, t: I)

src/processorimpl.rs:38

Functiononeway_test

src/net_stream.rs:141

(&mut self, event_loop: &mut Reactor, token: Token, hint: event::ReadHint)

src/reactor.rs:364

Methodremaining

src/reactor.rs:69

Runs in a loop, expects that its publisher might block

src/reactive.rs:43

process all incoming and outgoing events in a loop

src/reactor.rs:261

Functionstrbuf_to_isize

(buf: StreamBuf)

src/net_stream.rs:116

Methodsubscribe

(&mut self, s: Box<Subscriber<Input=O> + 'a>)

src/publisherimpl.rs:51

Methodsubscribe

(&mut self, s: Box<Subscriber<Input=I> + 'a>)

src/processorimpl.rs:29

src/publisherimpl.rs:57

(&mut self, event_loop: &mut Reactor, token: Token)

src/reactor.rs:440