opcua_types/service_types/
cancel_request.rs1#![allow(unused_attributes)]
9use std::io::{Read, Write};
10#[allow(unused_imports)]
11use crate::{
12 encoding::*,
13 basic_types::*,
14 service_types::impls::MessageInfo,
15 node_ids::ObjectId,
16 request_header::RequestHeader,
17};
18
19#[derive(Debug, Clone, PartialEq)]
20pub struct CancelRequest {
21 pub request_header: RequestHeader,
22 pub request_handle: u32,
23}
24
25impl MessageInfo for CancelRequest {
26 fn object_id(&self) -> ObjectId {
27 ObjectId::CancelRequest_Encoding_DefaultBinary
28 }
29}
30
31impl BinaryEncoder<CancelRequest> for CancelRequest {
32 fn byte_len(&self) -> usize {
33 let mut size = 0;
34 size += self.request_header.byte_len();
35 size += self.request_handle.byte_len();
36 size
37 }
38
39 #[allow(unused_variables)]
40 fn encode<S: Write>(&self, stream: &mut S) -> EncodingResult<usize> {
41 let mut size = 0;
42 size += self.request_header.encode(stream)?;
43 size += self.request_handle.encode(stream)?;
44 Ok(size)
45 }
46
47 #[allow(unused_variables)]
48 fn decode<S: Read>(stream: &mut S, decoding_options: &DecodingOptions) -> EncodingResult<Self> {
49 let request_header = RequestHeader::decode(stream, decoding_options)?;
50 let request_handle = u32::decode(stream, decoding_options)?;
51 Ok(CancelRequest {
52 request_header,
53 request_handle,
54 })
55 }
56}