ruststream-0.7.5
Platform
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

ruststream 0.7.5

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.

Crate
Source
Builds
Feature flags

..
pass
app_async_builder.rs
app_async_builder.stderr
app_builder_takes_arguments.rs
app_builder_takes_arguments.stderr
app_layer_after_with_broker.rs
app_layer_after_with_broker.stderr
app_on_startup_after_with_broker.rs
app_on_startup_after_with_broker.stderr
app_unknown_argument.rs
app_unknown_argument.stderr
app_unknown_flavor.rs
app_unknown_flavor.stderr
app_workers_on_current_thread.rs
app_workers_on_current_thread.stderr
app_zero_workers.rs
app_zero_workers.stderr
carried_batch_with_reply.rs
carried_batch_with_reply.stderr
carried_batch_without_carries.rs
carried_batch_without_carries.stderr
carried_without_carries.rs
carried_without_carries.stderr
lane_typo_both_wires.rs
lane_typo_both_wires.stderr
lane_typo_deserialize.rs
lane_typo_deserialize.stderr
lane_typo_deserialized.rs
lane_typo_deserialized.stderr
manual_slot_marker_mismatch.rs
manual_slot_marker_mismatch.stderr
manual_slot_transactional_mismatch.rs
manual_slot_transactional_mismatch.stderr
naming_transform_batch_reply.rs
naming_transform_batch_reply.stderr
naming_transform_declared_reply.rs
naming_transform_declared_reply.stderr
naming_transform_declared_slot.rs
naming_transform_declared_slot.stderr
naming_transform_retry_slot.rs
naming_transform_retry_slot.stderr
naming_transform_slot_transaction.rs
naming_transform_slot_transaction.stderr
naming_transform_twice.rs
naming_transform_twice.stderr
out_slot_duplicate_publishes.rs
out_slot_duplicate_publishes.stderr
out_slot_missing_build.rs
out_slot_missing_build.stderr
out_transform_without_slot.rs
out_transform_without_slot.stderr
out_typed_capability_mismatch.rs
out_typed_capability_mismatch.stderr
out_typed_not_in_list.rs
out_typed_not_in_list.stderr
out_typed_undeclared_message.rs
out_typed_undeclared_message.stderr
outgoing_bad_name.rs
outgoing_bad_name.stderr
publish_codec_on_serialized.rs
publish_codec_on_serialized.stderr
publish_missing_headers.rs
publish_missing_headers.stderr
publish_neither_wire.rs
publish_neither_wire.stderr
publish_no_destination.rs
publish_no_destination.stderr
publish_outside_dictionary.rs
publish_outside_dictionary.stderr
publish_template_missing_headers.rs
publish_template_missing_headers.stderr
publish_unbound_segment.rs
publish_unbound_segment.stderr
registration_layer_blanket_only.rs
registration_layer_blanket_only.stderr
reply_codec_named_twice.rs
reply_codec_named_twice.stderr
reply_name_template.rs
reply_name_template.stderr
reply_publisher_named_twice.rs
reply_publisher_named_twice.stderr
reply_transactional_mismatch.rs
reply_transactional_mismatch.stderr
reply_transactional_twice.rs
reply_transactional_twice.stderr
reply_transform_on_slot.rs
reply_transform_on_slot.stderr
reply_transform_other_options.rs
reply_transform_other_options.stderr
reply_transform_without_position.rs
reply_transform_without_position.stderr
reply_without_outgoing.rs
reply_without_outgoing.stderr
retry_bound_twice.rs
retry_bound_twice.stderr
retry_copies_without_default_publish.rs
retry_copies_without_default_publish.stderr
retry_declaration_dead_letter_twice.rs
retry_declaration_dead_letter_twice.stderr
retry_declaration_max_attempts_twice.rs
retry_declaration_max_attempts_twice.stderr
retry_destination_named_twice.rs
retry_destination_named_twice.stderr
retry_named_copies_router_without_destination.rs
retry_named_copies_router_without_destination.stderr
retry_publisher_on_closed_descriptor.rs
retry_publisher_on_closed_descriptor.stderr
slot_batch_transform_rejected.rs
slot_batch_transform_rejected.stderr
slot_transactional_rejected.rs
slot_transactional_rejected.stderr
slot_transform_other_options.rs
slot_transform_other_options.stderr
subscriber_bad_on_failure.rs
subscriber_bad_on_failure.stderr
subscriber_bare_slice_batch.rs
subscriber_bare_slice_batch.stderr
subscriber_bare_slice_param.rs
subscriber_bare_slice_param.stderr
subscriber_batch_named_twice.rs
subscriber_batch_named_twice.stderr
subscriber_batch_reply_not_vec.rs
subscriber_batch_reply_not_vec.stderr
subscriber_batch_slots_without_a_slice_body.rs
subscriber_batch_slots_without_a_slice_body.stderr
subscriber_batch_without_a_size.rs
subscriber_batch_without_a_size.stderr
subscriber_batch_without_a_slice_body.rs
subscriber_batch_without_a_slice_body.stderr
subscriber_batch_without_batching.rs
subscriber_batch_without_batching.stderr
subscriber_duplicate_reply.rs
subscriber_duplicate_reply.stderr
subscriber_headers_batch.rs
subscriber_headers_batch.stderr
subscriber_name_already_fixed.rs
subscriber_name_already_fixed.stderr
subscriber_out_capability_mismatch.rs
subscriber_out_capability_mismatch.stderr
subscriber_out_concrete_type.rs
subscriber_out_concrete_type.stderr
subscriber_out_duplicate_marker.rs
subscriber_out_duplicate_marker.stderr
subscriber_out_owned_mismatch.rs
subscriber_out_owned_mismatch.stderr
subscriber_out_unbound_slot.rs
subscriber_out_unbound_slot.stderr
subscriber_publish_retired.rs
subscriber_publish_retired.stderr
subscriber_reply_not_str.rs
subscriber_reply_not_str.stderr
subscriber_reply_unserializable.rs
subscriber_reply_unserializable.stderr
subscriber_source_free_function.rs
subscriber_source_free_function.stderr
subscriber_start_at_empty.rs
subscriber_start_at_empty.stderr
subscriber_start_at_free_fn.rs
subscriber_start_at_free_fn.stderr
subscriber_threads_after_workers.rs
subscriber_threads_after_workers.stderr
subscriber_threads_already_fixed.rs
subscriber_threads_already_fixed.stderr
subscriber_threads_zero.rs
subscriber_threads_zero.stderr
subscriber_unknown_clause.rs
subscriber_unknown_clause.stderr
subscriber_unnamed_mount.rs
subscriber_unnamed_mount.stderr
subscriber_workers_already_fixed.rs
subscriber_workers_already_fixed.stderr
subscriber_workers_bad_marker.rs
subscriber_workers_bad_marker.stderr
testing_register_without_in_process.rs
testing_register_without_in_process.stderr
wire_bad_signature.rs
wire_bad_signature.stderr
wire_half_declared.rs
wire_half_declared.stderr
wire_unknown_paths.rs
wire_unknown_paths.stderr