selium_remote_client_protocol/fbs/remote_client/protocol/
subscribe_request_generated.rs1extern crate alloc;
4use super::*;
5pub enum SubscribeRequestOffset {}
6#[derive(Copy, Clone, PartialEq)]
7
8pub struct SubscribeRequest<'a> {
9 pub _tab: ::flatbuffers::Table<'a>,
10}
11
12impl<'a> ::flatbuffers::Follow<'a> for SubscribeRequest<'a> {
13 type Inner = SubscribeRequest<'a>;
14 #[inline]
15 unsafe fn follow(buf: &'a [u8], loc: usize) -> Self::Inner {
16 Self { _tab: unsafe { ::flatbuffers::Table::new(buf, loc) } }
17 }
18}
19
20impl<'a> SubscribeRequest<'a> {
21 pub const VT_TARGET: ::flatbuffers::VOffsetT = 4;
22 pub const VT_CHUNK_SIZE: ::flatbuffers::VOffsetT = 6;
23
24 #[inline]
25 pub unsafe fn init_from_table(table: ::flatbuffers::Table<'a>) -> Self {
26 SubscribeRequest { _tab: table }
27 }
28 #[allow(unused_mut)]
29 pub fn create<'bldr: 'args, 'args: 'mut_bldr, 'mut_bldr, A: ::flatbuffers::Allocator + 'bldr>(
30 _fbb: &'mut_bldr mut ::flatbuffers::FlatBufferBuilder<'bldr, A>,
31 args: &'args SubscribeRequestArgs<'args>
32 ) -> ::flatbuffers::WIPOffset<SubscribeRequest<'bldr>> {
33 let mut builder = SubscribeRequestBuilder::new(_fbb);
34 builder.add_chunk_size(args.chunk_size);
35 if let Some(x) = args.target { builder.add_target(x); }
36 builder.finish()
37 }
38
39
40 #[inline]
41 pub fn target(&self) -> Option<ChannelRef<'a>> {
42 unsafe { self._tab.get::<::flatbuffers::ForwardsUOffset<ChannelRef>>(SubscribeRequest::VT_TARGET, None)}
46 }
47 #[inline]
48 pub fn chunk_size(&self) -> u32 {
49 unsafe { self._tab.get::<u32>(SubscribeRequest::VT_CHUNK_SIZE, Some(0)).unwrap()}
53 }
54}
55
56impl ::flatbuffers::Verifiable for SubscribeRequest<'_> {
57 #[inline]
58 fn run_verifier(
59 v: &mut ::flatbuffers::Verifier, pos: usize
60 ) -> Result<(), ::flatbuffers::InvalidFlatbuffer> {
61 v.visit_table(pos)?
62 .visit_field::<::flatbuffers::ForwardsUOffset<ChannelRef>>("target", Self::VT_TARGET, false)?
63 .visit_field::<u32>("chunk_size", Self::VT_CHUNK_SIZE, false)?
64 .finish();
65 Ok(())
66 }
67}
68pub struct SubscribeRequestArgs<'a> {
69 pub target: Option<::flatbuffers::WIPOffset<ChannelRef<'a>>>,
70 pub chunk_size: u32,
71}
72impl<'a> Default for SubscribeRequestArgs<'a> {
73 #[inline]
74 fn default() -> Self {
75 SubscribeRequestArgs {
76 target: None,
77 chunk_size: 0,
78 }
79 }
80}
81
82pub struct SubscribeRequestBuilder<'a: 'b, 'b, A: ::flatbuffers::Allocator + 'a> {
83 fbb_: &'b mut ::flatbuffers::FlatBufferBuilder<'a, A>,
84 start_: ::flatbuffers::WIPOffset<::flatbuffers::TableUnfinishedWIPOffset>,
85}
86impl<'a: 'b, 'b, A: ::flatbuffers::Allocator + 'a> SubscribeRequestBuilder<'a, 'b, A> {
87 #[inline]
88 pub fn add_target(&mut self, target: ::flatbuffers::WIPOffset<ChannelRef<'b >>) {
89 self.fbb_.push_slot_always::<::flatbuffers::WIPOffset<ChannelRef>>(SubscribeRequest::VT_TARGET, target);
90 }
91 #[inline]
92 pub fn add_chunk_size(&mut self, chunk_size: u32) {
93 self.fbb_.push_slot::<u32>(SubscribeRequest::VT_CHUNK_SIZE, chunk_size, 0);
94 }
95 #[inline]
96 pub fn new(_fbb: &'b mut ::flatbuffers::FlatBufferBuilder<'a, A>) -> SubscribeRequestBuilder<'a, 'b, A> {
97 let start = _fbb.start_table();
98 SubscribeRequestBuilder {
99 fbb_: _fbb,
100 start_: start,
101 }
102 }
103 #[inline]
104 pub fn finish(self) -> ::flatbuffers::WIPOffset<SubscribeRequest<'a>> {
105 let o = self.fbb_.end_table(self.start_);
106 ::flatbuffers::WIPOffset::new(o.value())
107 }
108}
109
110impl ::core::fmt::Debug for SubscribeRequest<'_> {
111 fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
112 let mut ds = f.debug_struct("SubscribeRequest");
113 ds.field("target", &self.target());
114 ds.field("chunk_size", &self.chunk_size());
115 ds.finish()
116 }
117}