) -> Buffer<u8> {
let mut dispatch = |b| dispatcher.dispatch(b);
- run_client(
- Bridge {
- cached_buffer: input,
- dispatch: (&mut dispatch).into(),
- },
- client_data,
- )
+ run_client(Bridge { cached_buffer: input, dispatch: (&mut dispatch).into() }, client_data)
}
}
};
run_client(
- Bridge {
- cached_buffer: input,
- dispatch: (&mut dispatch).into(),
- },
+ Bridge { cached_buffer: input, dispatch: (&mut dispatch).into() },
client_data,
)
});
};
let r = run_client(
- Bridge {
- cached_buffer: input,
- dispatch: (&mut dispatch).into(),
- },
+ Bridge { cached_buffer: input, dispatch: (&mut dispatch).into() },
client_data,
);
run_client: extern "C" fn(Bridge<'_>, D) -> Buffer<u8>,
client_data: D,
) -> Result<O, PanicMessage> {
- let mut dispatcher = Dispatcher {
- handle_store: HandleStore::new(handle_counters),
- server: MarkedTypes(server),
- };
+ let mut dispatcher =
+ Dispatcher { handle_store: HandleStore::new(handle_counters), server: MarkedTypes(server) };
let mut b = Buffer::new();
input.encode(&mut b, &mut dispatcher.handle_store);
server: S,
input: S::TokenStream,
) -> Result<S::TokenStream, PanicMessage> {
- let client::Client {
- get_handle_counters,
- run,
- f,
- } = *self;
+ let client::Client { get_handle_counters, run, f } = *self;
run_server(
strategy,
get_handle_counters(),
input: S::TokenStream,
input2: S::TokenStream,
) -> Result<S::TokenStream, PanicMessage> {
- let client::Client {
- get_handle_counters,
- run,
- f,
- } = *self;
+ let client::Client { get_handle_counters, run, f } = *self;
run_server(
strategy,
get_handle_counters(),