polyester-sdk 0.1.0-alpha.27

// @generated by connectrpc-codegen. DO NOT EDIT.

///Shorthand for `OwnedView<PreviewOrderRequestView<'static>>`.
pub type OwnedPreviewOrderRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::PreviewOrderRequestView<'static>,
>;
///Shorthand for `OwnedView<PreviewOrderResponseView<'static>>`.
pub type OwnedPreviewOrderResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::PreviewOrderResponseView<'static>,
>;
///Shorthand for `OwnedView<CreateOrderRequestView<'static>>`.
pub type OwnedCreateOrderRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CreateOrderRequestView<'static>,
>;
///Shorthand for `OwnedView<CreateOrderResponseView<'static>>`.
pub type OwnedCreateOrderResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CreateOrderResponseView<'static>,
>;
///Shorthand for `OwnedView<CancelOrderRequestView<'static>>`.
pub type OwnedCancelOrderRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelOrderRequestView<'static>,
>;
///Shorthand for `OwnedView<CancelOrderResponseView<'static>>`.
pub type OwnedCancelOrderResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelOrderResponseView<'static>,
>;
///Shorthand for `OwnedView<CancelAllOrdersRequestView<'static>>`.
pub type OwnedCancelAllOrdersRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelAllOrdersRequestView<'static>,
>;
///Shorthand for `OwnedView<CancelAllOrdersResponseView<'static>>`.
pub type OwnedCancelAllOrdersResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelAllOrdersResponseView<'static>,
>;
///Shorthand for `OwnedView<CancelAllAfterRequestView<'static>>`.
pub type OwnedCancelAllAfterRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelAllAfterRequestView<'static>,
>;
///Shorthand for `OwnedView<CancelAllAfterResponseView<'static>>`.
pub type OwnedCancelAllAfterResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelAllAfterResponseView<'static>,
>;
///Shorthand for `OwnedView<BatchCreateOrdersRequestView<'static>>`.
pub type OwnedBatchCreateOrdersRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchCreateOrdersRequestView<'static>,
>;
///Shorthand for `OwnedView<BatchCreateOrdersResponseView<'static>>`.
pub type OwnedBatchCreateOrdersResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchCreateOrdersResponseView<'static>,
>;
///Shorthand for `OwnedView<ModifyOrderRequestView<'static>>`.
pub type OwnedModifyOrderRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::ModifyOrderRequestView<'static>,
>;
///Shorthand for `OwnedView<ModifyOrderResponseView<'static>>`.
pub type OwnedModifyOrderResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::ModifyOrderResponseView<'static>,
>;
///Shorthand for `OwnedView<BatchReplaceOrdersRequestView<'static>>`.
pub type OwnedBatchReplaceOrdersRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersRequestView<'static>,
>;
///Shorthand for `OwnedView<BatchReplaceOrdersResponseView<'static>>`.
pub type OwnedBatchReplaceOrdersResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersResponseView<'static>,
>;
///Shorthand for `OwnedView<BatchCancelOrdersRequestView<'static>>`.
pub type OwnedBatchCancelOrdersRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchCancelOrdersRequestView<'static>,
>;
///Shorthand for `OwnedView<BatchCancelOrdersResponseView<'static>>`.
pub type OwnedBatchCancelOrdersResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchCancelOrdersResponseView<'static>,
>;
impl ::connectrpc::Encodable<crate::proto::orders::v1::PreviewOrderResponse>
for crate::proto::orders::v1::__buffa::view::PreviewOrderResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::PreviewOrderResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::PreviewOrderResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CreateOrderResponse>
for crate::proto::orders::v1::__buffa::view::CreateOrderResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CreateOrderResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CreateOrderResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CancelOrderResponse>
for crate::proto::orders::v1::__buffa::view::CancelOrderResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CancelOrderResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelOrderResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CancelAllOrdersResponse>
for crate::proto::orders::v1::__buffa::view::CancelAllOrdersResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CancelAllOrdersResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelAllOrdersResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CancelAllAfterResponse>
for crate::proto::orders::v1::__buffa::view::CancelAllAfterResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::CancelAllAfterResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::CancelAllAfterResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::BatchCreateOrdersResponse>
for crate::proto::orders::v1::__buffa::view::BatchCreateOrdersResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::BatchCreateOrdersResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchCreateOrdersResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::ModifyOrderResponse>
for crate::proto::orders::v1::__buffa::view::ModifyOrderResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::ModifyOrderResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::ModifyOrderResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::BatchReplaceOrdersResponse>
for crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::BatchReplaceOrdersResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::BatchCancelOrdersResponse>
for crate::proto::orders::v1::__buffa::view::BatchCancelOrdersResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::BatchCancelOrdersResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::BatchCancelOrdersResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
/// Full service name for this service.
pub const ORDERS_SERVICE_SERVICE_NAME: &str = "orders.v1.OrdersService";
/// Static [`Spec`](::connectrpc::Spec) for the server-side `PreviewOrder` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_PREVIEW_ORDER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/PreviewOrder",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `CreateOrder` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_CREATE_ORDER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/CreateOrder",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `CancelOrder` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_CANCEL_ORDER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/CancelOrder",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `CancelAllOrders` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_CANCEL_ALL_ORDERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/CancelAllOrders",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `CancelAllAfter` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_CANCEL_ALL_AFTER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/CancelAllAfter",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `BatchCreateOrders` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_BATCH_CREATE_ORDERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/BatchCreateOrders",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ModifyOrder` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_MODIFY_ORDER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/ModifyOrder",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `BatchReplaceOrders` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_BATCH_REPLACE_ORDERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/BatchReplaceOrders",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `BatchCancelOrders` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_SERVICE_BATCH_CANCEL_ORDERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersService/BatchCancelOrders",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Server trait for OrdersService.
///
/// # Implementing handlers
///
/// Implement methods with plain `async fn`; the returned future satisfies
/// the `Send` bound automatically.
///
/// **Unary and server-streaming requests** arrive as
/// [`ServiceRequest<'_, Req>`](::connectrpc::ServiceRequest): a zero-copy
/// view of the request plus its body, valid for the duration of the call.
/// Fields are read directly (`request.name` is a `&str` into the decoded
/// buffer) and the borrow may be held across `.await` points. Anything
/// that must outlive the call — `tokio::spawn`, channels, server state,
/// or data captured by a returned response stream — takes owned data:
/// call `request.to_owned_message()` (or copy the specific fields)
/// first.
///
/// **Client-streaming and bidi requests** arrive as
/// [`InboundStream<Req>`](::connectrpc::InboundStream) — a
/// `ServiceStream` of [`StreamMessage`](::connectrpc::StreamMessage)s.
/// Each item owns its decoded buffer and is `Send + 'static`, so items
/// can be buffered or moved into spawned tasks; read fields zero-copy
/// through the generated accessor methods (`item.name()`) or `.view()`,
/// convert with `.to_owned_message()`, or yield an item back unchanged —
/// `StreamMessage<M>` implements `Encodable<M>`.
///
/// Request types resolved through `extern_path` (e.g. well-known types
/// from another crate) use the same wrappers; the crate that owns the
/// type must be generated with buffa ≥ 0.8.0 and views enabled so the
/// backing `HasMessageView` impl exists.
///
/// The `impl Encodable<Out>` return bound accepts the owned `Out`, the
/// generated `OutView<'_>` / `OwnedOutView`,
/// [`MaybeBorrowed`](::connectrpc::MaybeBorrowed), or
/// [`PreEncoded`](::connectrpc::PreEncoded) for handlers that encode a
/// non-`'static` view internally and pass the bytes across the handler
/// boundary. View bodies are not emitted for output types mapped via
/// `extern_path` (the impl would be an orphan); return owned for
/// WKT/extern outputs.
///
/// Server-streaming and bidi-streaming methods return
/// `ServiceStream<impl Encodable<Out> + Send + use<Self>>`. The
/// `use<Self>` precise-capturing clause excludes `&self`'s lifetime and
/// the request's lifetime (unary methods use `use<'a, Self>` and may
/// borrow from `&self`), so stream items must be `'static` and cannot
/// borrow from the request. To stream view-encoded data, encode each
/// item inside the stream body and yield
/// [`PreEncoded`](::connectrpc::PreEncoded) — see its `# Streaming
/// example` doc.
#[allow(clippy::type_complexity)]
pub trait OrdersService: Send + Sync + 'static {
    /// Check whether an order is currently admissible without creating an order,
    /// claiming its client order ID, or reserving funds.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn preview_order<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::PreviewOrderRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::PreviewOrderResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Create a new order.
    /// REST clients submit decimal quantity and price strings. ConnectRPC clients
    /// submit scaled integer values.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn create_order<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::CreateOrderRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::CreateOrderResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Cancels an existing order by id or client order id.
    /// REST clients submit base58 order IDs. ConnectRPC clients submit fixed64
    /// order IDs.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn cancel_order<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::CancelOrderRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::CancelOrderResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Cancels all matching open orders for an account (kill switch).
    /// Evaluates matching orders from a consistent snapshot at request start.
    /// Final state is confirmed via the order update stream or read path.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn cancel_all_orders<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::CancelAllOrdersRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::CancelAllOrdersResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Set cancel-all-after (dead-man switch).
    /// Arms or disables automatic cancel-all if heartbeat is not refreshed before expiry.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn cancel_all_after<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::CancelAllAfterRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::CancelAllAfterResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Places multiple orders in a single request (best-effort per item).
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn batch_create_orders<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::BatchCreateOrdersRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::BatchCreateOrdersResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Modifies an existing order using explicit behavior policy.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn modify_order<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::ModifyOrderRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::ModifyOrderResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Replaces same-symbol orders and returns after authoritative admission.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn batch_replace_orders<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::BatchReplaceOrdersRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::BatchReplaceOrdersResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Cancels multiple orders by explicit ID in a single request.
    /// Per-item results are returned; partial success is the default.
    /// Final state is confirmed via the order update stream or read path.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn batch_cancel_orders<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::BatchCancelOrdersRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::BatchCancelOrdersResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
}
/// Extension trait for registering a service implementation with a Router.
///
/// This trait is automatically implemented for all types that implement the service trait.
/// Prefer [`Router::add_service`](::connectrpc::Router::add_service) for
/// top-down registration; `register` remains available for compatibility
/// and cases where the service-first call shape is more convenient.
///
/// # Example
///
/// ```rust,ignore
/// use std::sync::Arc;
///
/// let service = Arc::new(MyServiceImpl);
/// let router = service.register(Router::new());
/// ```
pub trait OrdersServiceExt: OrdersService {
    /// Register this service implementation with a Router.
    ///
    /// Takes ownership of the `Arc<Self>` and returns a new Router with
    /// this service's methods registered.
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router;
}
impl<S: OrdersService> OrdersServiceExt for S {
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router {
        router
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "PreviewOrder",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::PreviewOrderRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::PreviewOrderRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.preview_order(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::PreviewOrderResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_PREVIEW_ORDER_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "CreateOrder",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::CreateOrderRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::CreateOrderRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.create_order(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::CreateOrderResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_CREATE_ORDER_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "CancelOrder",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::CancelOrderRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::CancelOrderRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.cancel_order(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::CancelOrderResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_CANCEL_ORDER_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "CancelAllOrders",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::CancelAllOrdersRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::CancelAllOrdersRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.cancel_all_orders(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::CancelAllOrdersResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_CANCEL_ALL_ORDERS_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "CancelAllAfter",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::CancelAllAfterRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::CancelAllAfterRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.cancel_all_after(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::CancelAllAfterResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_CANCEL_ALL_AFTER_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "BatchCreateOrders",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::BatchCreateOrdersRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::BatchCreateOrdersRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.batch_create_orders(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::BatchCreateOrdersResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_BATCH_CREATE_ORDERS_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "ModifyOrder",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::ModifyOrderRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::ModifyOrderRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.modify_order(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::ModifyOrderResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_MODIFY_ORDER_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "BatchReplaceOrders",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::BatchReplaceOrdersRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.batch_replace_orders(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::BatchReplaceOrdersResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_BATCH_REPLACE_ORDERS_SPEC)
            .route_view(
                ORDERS_SERVICE_SERVICE_NAME,
                "BatchCancelOrders",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::BatchCancelOrdersRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::BatchCancelOrdersRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.batch_cancel_orders(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::BatchCancelOrdersResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_SERVICE_BATCH_CANCEL_ORDERS_SPEC)
    }
}
/// Type-inference marker used by [`Router::add_service`](::connectrpc::Router::add_service).
#[doc(hidden)]
pub struct OrdersServiceRegisterMarker;
impl<S: OrdersService> ::connectrpc::ServiceRegister<OrdersServiceRegisterMarker>
for ::std::sync::Arc<S> {
    fn register_service(self, router: ::connectrpc::Router) -> ::connectrpc::Router {
        <S as OrdersServiceExt>::register(self, router)
    }
}
/// Monomorphic dispatcher for `OrdersService`.
///
/// Unlike `.register(Router)` which type-erases each method into an `Arc<dyn ErasedHandler>` stored in a `HashMap`, this struct dispatches via a compile-time `match` on method name: no vtable, no hash lookup.
///
/// # Example
///
/// ```rust,ignore
/// use connectrpc::ConnectRpcService;
///
/// let server = OrdersServiceServer::new(MyImpl);
/// let service = ConnectRpcService::new(server);
/// // hand `service` to axum/hyper as a fallback_service
/// ```
pub struct OrdersServiceServer<T> {
    inner: ::std::sync::Arc<T>,
}
impl<T: OrdersService> OrdersServiceServer<T> {
    /// Wrap a service implementation in a monomorphic dispatcher.
    pub fn new(service: T) -> Self {
        Self {
            inner: ::std::sync::Arc::new(service),
        }
    }
    /// Wrap an already-`Arc`'d service implementation.
    pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
        Self { inner }
    }
}
impl<T> Clone for OrdersServiceServer<T> {
    fn clone(&self) -> Self {
        Self {
            inner: ::std::sync::Arc::clone(&self.inner),
        }
    }
}
impl<T: OrdersService> ::connectrpc::Dispatcher for OrdersServiceServer<T> {
    #[inline]
    fn lookup(
        &self,
        path: &str,
    ) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
        let method = path.strip_prefix("orders.v1.OrdersService/")?;
        match method {
            "PreviewOrder" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_PREVIEW_ORDER_SPEC),
                )
            }
            "CreateOrder" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_CREATE_ORDER_SPEC),
                )
            }
            "CancelOrder" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_CANCEL_ORDER_SPEC),
                )
            }
            "CancelAllOrders" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_CANCEL_ALL_ORDERS_SPEC),
                )
            }
            "CancelAllAfter" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_CANCEL_ALL_AFTER_SPEC),
                )
            }
            "BatchCreateOrders" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_BATCH_CREATE_ORDERS_SPEC),
                )
            }
            "ModifyOrder" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_MODIFY_ORDER_SPEC),
                )
            }
            "BatchReplaceOrders" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_BATCH_REPLACE_ORDERS_SPEC),
                )
            }
            "BatchCancelOrders" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_SERVICE_BATCH_CANCEL_ORDERS_SPEC),
                )
            }
            _ => None,
        }
    }
    fn call_unary(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::Payload,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            "PreviewOrder" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::PreviewOrderRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::PreviewOrderRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::PreviewOrderRequest,
                    >::from_parts(&req, &body);
                    svc.preview_order(ctx, req)
                        .await?
                        .encode::<crate::proto::orders::v1::PreviewOrderResponse>(format)
                })
            }
            "CreateOrder" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::CreateOrderRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::CreateOrderRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::CreateOrderRequest,
                    >::from_parts(&req, &body);
                    svc.create_order(ctx, req)
                        .await?
                        .encode::<crate::proto::orders::v1::CreateOrderResponse>(format)
                })
            }
            "CancelOrder" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::CancelOrderRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::CancelOrderRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::CancelOrderRequest,
                    >::from_parts(&req, &body);
                    svc.cancel_order(ctx, req)
                        .await?
                        .encode::<crate::proto::orders::v1::CancelOrderResponse>(format)
                })
            }
            "CancelAllOrders" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::CancelAllOrdersRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::CancelAllOrdersRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::CancelAllOrdersRequest,
                    >::from_parts(&req, &body);
                    svc.cancel_all_orders(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::CancelAllOrdersResponse,
                        >(format)
                })
            }
            "CancelAllAfter" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::CancelAllAfterRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::CancelAllAfterRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::CancelAllAfterRequest,
                    >::from_parts(&req, &body);
                    svc.cancel_all_after(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::CancelAllAfterResponse,
                        >(format)
                })
            }
            "BatchCreateOrders" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::BatchCreateOrdersRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::BatchCreateOrdersRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::BatchCreateOrdersRequest,
                    >::from_parts(&req, &body);
                    svc.batch_create_orders(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::BatchCreateOrdersResponse,
                        >(format)
                })
            }
            "ModifyOrder" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::ModifyOrderRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::ModifyOrderRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::ModifyOrderRequest,
                    >::from_parts(&req, &body);
                    svc.modify_order(ctx, req)
                        .await?
                        .encode::<crate::proto::orders::v1::ModifyOrderResponse>(format)
                })
            }
            "BatchReplaceOrders" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::BatchReplaceOrdersRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::BatchReplaceOrdersRequest,
                    >::from_parts(&req, &body);
                    svc.batch_replace_orders(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::BatchReplaceOrdersResponse,
                        >(format)
                })
            }
            "BatchCancelOrders" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::BatchCancelOrdersRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::BatchCancelOrdersRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::BatchCancelOrdersRequest,
                    >::from_parts(&req, &body);
                    svc.batch_cancel_orders(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::BatchCancelOrdersResponse,
                        >(format)
                })
            }
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_server_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::buffa::bytes::Bytes,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
    fn call_client_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_bidi_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
}
/// Client for this service.
///
/// Generic over `T: ClientTransport`. For **gRPC** (HTTP/2), use
/// `Http2Connection` — it has honest `poll_ready` and composes with
/// `tower::balance` for multi-connection load balancing. For **Connect
/// over HTTP/1.1** (or unknown protocol), use `HttpClient`.
///
/// # Working with the response
///
/// Unary calls return [`UnaryResponse<OwnedView<FooView>>`](::connectrpc::client::UnaryResponse).
/// [`view()`](::connectrpc::client::UnaryResponse::view) borrows the response
/// message, so field access is zero-copy:
///
/// ```rust,ignore
/// let resp = client.preview_order(request).await?;
/// let name: &str = resp.view().name;  // borrow into the response buffer
/// ```
///
/// If you need the owned struct (e.g. to store or pass by value), use
/// [`into_owned()`](::connectrpc::client::UnaryResponse::into_owned):
///
/// ```rust,ignore
/// let owned = client.preview_order(request).await?.into_owned();
/// ```
///
/// [`into_view()`](::connectrpc::client::UnaryResponse::into_view) keeps the
/// zero-copy decoded body (an `OwnedView`) without copying; field access on it
/// goes through `.reborrow()`. Streaming responses yield one
/// [`StreamMessage`](::connectrpc::StreamMessage) per received message from
/// `.message().await` — read fields zero-copy through the generated accessor
/// methods (`msg.name()`) or `.view()`, or convert with `.to_owned_message()`.
#[derive(Clone)]
pub struct OrdersServiceClient<T> {
    transport: T,
    config: ::connectrpc::client::ClientConfig,
}
impl<T> OrdersServiceClient<T>
where
    T: ::connectrpc::client::ClientTransport,
    <T::ResponseBody as ::connectrpc::http_body::Body>::Error: ::std::fmt::Display,
{
    /// Create a new client with the given transport and configuration.
    pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
        Self { transport, config }
    }
    /// Get the client configuration.
    pub fn config(&self) -> &::connectrpc::client::ClientConfig {
        &self.config
    }
    /// Get a mutable reference to the client configuration.
    pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
        &mut self.config
    }
    /// Call the PreviewOrder RPC. Sends a request to /orders.v1.OrdersService/PreviewOrder.
    pub async fn preview_order(
        &self,
        request: crate::proto::orders::v1::PreviewOrderRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::PreviewOrderResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.preview_order_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the PreviewOrder RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn preview_order_with_options(
        &self,
        request: crate::proto::orders::v1::PreviewOrderRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::PreviewOrderResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "PreviewOrder",
                request,
                options,
            )
            .await
    }
    /// Call the CreateOrder RPC. Sends a request to /orders.v1.OrdersService/CreateOrder.
    pub async fn create_order(
        &self,
        request: crate::proto::orders::v1::CreateOrderRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CreateOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.create_order_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the CreateOrder RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn create_order_with_options(
        &self,
        request: crate::proto::orders::v1::CreateOrderRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CreateOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "CreateOrder",
                request,
                options,
            )
            .await
    }
    /// Call the CancelOrder RPC. Sends a request to /orders.v1.OrdersService/CancelOrder.
    pub async fn cancel_order(
        &self,
        request: crate::proto::orders::v1::CancelOrderRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CancelOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.cancel_order_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the CancelOrder RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn cancel_order_with_options(
        &self,
        request: crate::proto::orders::v1::CancelOrderRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CancelOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "CancelOrder",
                request,
                options,
            )
            .await
    }
    /// Call the CancelAllOrders RPC. Sends a request to /orders.v1.OrdersService/CancelAllOrders.
    pub async fn cancel_all_orders(
        &self,
        request: crate::proto::orders::v1::CancelAllOrdersRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CancelAllOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.cancel_all_orders_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the CancelAllOrders RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn cancel_all_orders_with_options(
        &self,
        request: crate::proto::orders::v1::CancelAllOrdersRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CancelAllOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "CancelAllOrders",
                request,
                options,
            )
            .await
    }
    /// Call the CancelAllAfter RPC. Sends a request to /orders.v1.OrdersService/CancelAllAfter.
    pub async fn cancel_all_after(
        &self,
        request: crate::proto::orders::v1::CancelAllAfterRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CancelAllAfterResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.cancel_all_after_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the CancelAllAfter RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn cancel_all_after_with_options(
        &self,
        request: crate::proto::orders::v1::CancelAllAfterRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::CancelAllAfterResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "CancelAllAfter",
                request,
                options,
            )
            .await
    }
    /// Call the BatchCreateOrders RPC. Sends a request to /orders.v1.OrdersService/BatchCreateOrders.
    pub async fn batch_create_orders(
        &self,
        request: crate::proto::orders::v1::BatchCreateOrdersRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::BatchCreateOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.batch_create_orders_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the BatchCreateOrders RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn batch_create_orders_with_options(
        &self,
        request: crate::proto::orders::v1::BatchCreateOrdersRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::BatchCreateOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "BatchCreateOrders",
                request,
                options,
            )
            .await
    }
    /// Call the ModifyOrder RPC. Sends a request to /orders.v1.OrdersService/ModifyOrder.
    pub async fn modify_order(
        &self,
        request: crate::proto::orders::v1::ModifyOrderRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::ModifyOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.modify_order_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ModifyOrder RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn modify_order_with_options(
        &self,
        request: crate::proto::orders::v1::ModifyOrderRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::ModifyOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "ModifyOrder",
                request,
                options,
            )
            .await
    }
    /// Call the BatchReplaceOrders RPC. Sends a request to /orders.v1.OrdersService/BatchReplaceOrders.
    pub async fn batch_replace_orders(
        &self,
        request: crate::proto::orders::v1::BatchReplaceOrdersRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.batch_replace_orders_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the BatchReplaceOrders RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn batch_replace_orders_with_options(
        &self,
        request: crate::proto::orders::v1::BatchReplaceOrdersRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::BatchReplaceOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "BatchReplaceOrders",
                request,
                options,
            )
            .await
    }
    /// Call the BatchCancelOrders RPC. Sends a request to /orders.v1.OrdersService/BatchCancelOrders.
    pub async fn batch_cancel_orders(
        &self,
        request: crate::proto::orders::v1::BatchCancelOrdersRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::BatchCancelOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.batch_cancel_orders_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the BatchCancelOrders RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn batch_cancel_orders_with_options(
        &self,
        request: crate::proto::orders::v1::BatchCancelOrdersRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::BatchCancelOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_SERVICE_SERVICE_NAME,
                "BatchCancelOrders",
                request,
                options,
            )
            .await
    }
}

///Shorthand for `OwnedView<GetOpenOrdersRequestView<'static>>`.
pub type OwnedGetOpenOrdersRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOpenOrdersRequestView<'static>,
>;
///Shorthand for `OwnedView<GetOpenOrdersResponseView<'static>>`.
pub type OwnedGetOpenOrdersResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOpenOrdersResponseView<'static>,
>;
///Shorthand for `OwnedView<GetOrderHistoryRequestView<'static>>`.
pub type OwnedGetOrderHistoryRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOrderHistoryRequestView<'static>,
>;
///Shorthand for `OwnedView<GetOrderHistoryResponseView<'static>>`.
pub type OwnedGetOrderHistoryResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOrderHistoryResponseView<'static>,
>;
///Shorthand for `OwnedView<GetUserTradesRequestView<'static>>`.
pub type OwnedGetUserTradesRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetUserTradesRequestView<'static>,
>;
///Shorthand for `OwnedView<GetUserTradesResponseView<'static>>`.
pub type OwnedGetUserTradesResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetUserTradesResponseView<'static>,
>;
///Shorthand for `OwnedView<GetOrderRequestView<'static>>`.
pub type OwnedGetOrderRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOrderRequestView<'static>,
>;
///Shorthand for `OwnedView<GetOrderResponseView<'static>>`.
pub type OwnedGetOrderResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOrderResponseView<'static>,
>;
///Shorthand for `OwnedView<GetBatchReplaceStatusRequestView<'static>>`.
pub type OwnedGetBatchReplaceStatusRequestView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusRequestView<'static>,
>;
///Shorthand for `OwnedView<GetBatchReplaceStatusResponseView<'static>>`.
pub type OwnedGetBatchReplaceStatusResponseView = ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusResponseView<'static>,
>;
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetOpenOrdersResponse>
for crate::proto::orders::v1::__buffa::view::GetOpenOrdersResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetOpenOrdersResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOpenOrdersResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetOrderHistoryResponse>
for crate::proto::orders::v1::__buffa::view::GetOrderHistoryResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetOrderHistoryResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOrderHistoryResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetUserTradesResponse>
for crate::proto::orders::v1::__buffa::view::GetUserTradesResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetUserTradesResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetUserTradesResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetOrderResponse>
for crate::proto::orders::v1::__buffa::view::GetOrderResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetOrderResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetOrderResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetBatchReplaceStatusResponse>
for crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::orders::v1::GetBatchReplaceStatusResponse>
for ::buffa::view::OwnedView<
    crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
/// Full service name for this service.
pub const ORDERS_READ_SERVICE_SERVICE_NAME: &str = "orders.v1.OrdersReadService";
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetOpenOrders` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_READ_SERVICE_GET_OPEN_ORDERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersReadService/GetOpenOrders",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetOrderHistory` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_READ_SERVICE_GET_ORDER_HISTORY_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersReadService/GetOrderHistory",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetUserTrades` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_READ_SERVICE_GET_USER_TRADES_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersReadService/GetUserTrades",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetOrder` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_READ_SERVICE_GET_ORDER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersReadService/GetOrder",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetBatchReplaceStatus` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const ORDERS_READ_SERVICE_GET_BATCH_REPLACE_STATUS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/orders.v1.OrdersReadService/GetBatchReplaceStatus",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Server trait for OrdersReadService.
///
/// # Implementing handlers
///
/// Implement methods with plain `async fn`; the returned future satisfies
/// the `Send` bound automatically.
///
/// **Unary and server-streaming requests** arrive as
/// [`ServiceRequest<'_, Req>`](::connectrpc::ServiceRequest): a zero-copy
/// view of the request plus its body, valid for the duration of the call.
/// Fields are read directly (`request.name` is a `&str` into the decoded
/// buffer) and the borrow may be held across `.await` points. Anything
/// that must outlive the call — `tokio::spawn`, channels, server state,
/// or data captured by a returned response stream — takes owned data:
/// call `request.to_owned_message()` (or copy the specific fields)
/// first.
///
/// **Client-streaming and bidi requests** arrive as
/// [`InboundStream<Req>`](::connectrpc::InboundStream) — a
/// `ServiceStream` of [`StreamMessage`](::connectrpc::StreamMessage)s.
/// Each item owns its decoded buffer and is `Send + 'static`, so items
/// can be buffered or moved into spawned tasks; read fields zero-copy
/// through the generated accessor methods (`item.name()`) or `.view()`,
/// convert with `.to_owned_message()`, or yield an item back unchanged —
/// `StreamMessage<M>` implements `Encodable<M>`.
///
/// Request types resolved through `extern_path` (e.g. well-known types
/// from another crate) use the same wrappers; the crate that owns the
/// type must be generated with buffa ≥ 0.8.0 and views enabled so the
/// backing `HasMessageView` impl exists.
///
/// The `impl Encodable<Out>` return bound accepts the owned `Out`, the
/// generated `OutView<'_>` / `OwnedOutView`,
/// [`MaybeBorrowed`](::connectrpc::MaybeBorrowed), or
/// [`PreEncoded`](::connectrpc::PreEncoded) for handlers that encode a
/// non-`'static` view internally and pass the bytes across the handler
/// boundary. View bodies are not emitted for output types mapped via
/// `extern_path` (the impl would be an orphan); return owned for
/// WKT/extern outputs.
///
/// Server-streaming and bidi-streaming methods return
/// `ServiceStream<impl Encodable<Out> + Send + use<Self>>`. The
/// `use<Self>` precise-capturing clause excludes `&self`'s lifetime and
/// the request's lifetime (unary methods use `use<'a, Self>` and may
/// borrow from `&self`), so stream items must be `'static` and cannot
/// borrow from the request. To stream view-encoded data, encode each
/// item inside the stream body and yield
/// [`PreEncoded`](::connectrpc::PreEncoded) — see its `# Streaming
/// example` doc.
#[allow(clippy::type_complexity)]
pub trait OrdersReadService: Send + Sync + 'static {
    /// Retrieve non-terminal orders for an account.
    /// Supports optional subaccount, symbol, and side filters with cursor pagination.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_open_orders<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::GetOpenOrdersRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::GetOpenOrdersResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Retrieve terminal order history for an account.
    /// Supports optional subaccount, symbol, side, status, and time-range filters with cursor pagination.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_order_history<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::GetOrderHistoryRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::GetOrderHistoryResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Retrieve per-user trade fills for an account.
    /// Supports optional subaccount, symbol, side, and time-range filters with cursor pagination.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_user_trades<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::GetUserTradesRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::GetUserTradesResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Retrieve a single order by order ID or client order ID, including related user trades and ledger transfers.
    /// Recent accepted orders may wait briefly for read availability; retry UNAVAILABLE with the same lookup key.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_order<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::GetOrderRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::GetOrderResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Retrieve durable execution status for one admitted batch replacement.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_batch_replace_status<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::orders::v1::GetBatchReplaceStatusRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::orders::v1::GetBatchReplaceStatusResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
}
/// Extension trait for registering a service implementation with a Router.
///
/// This trait is automatically implemented for all types that implement the service trait.
/// Prefer [`Router::add_service`](::connectrpc::Router::add_service) for
/// top-down registration; `register` remains available for compatibility
/// and cases where the service-first call shape is more convenient.
///
/// # Example
///
/// ```rust,ignore
/// use std::sync::Arc;
///
/// let service = Arc::new(MyServiceImpl);
/// let router = service.register(Router::new());
/// ```
pub trait OrdersReadServiceExt: OrdersReadService {
    /// Register this service implementation with a Router.
    ///
    /// Takes ownership of the `Arc<Self>` and returns a new Router with
    /// this service's methods registered.
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router;
}
impl<S: OrdersReadService> OrdersReadServiceExt for S {
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router {
        router
            .route_view(
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetOpenOrders",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::GetOpenOrdersRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::GetOpenOrdersRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_open_orders(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::GetOpenOrdersResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_READ_SERVICE_GET_OPEN_ORDERS_SPEC)
            .route_view(
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetOrderHistory",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::GetOrderHistoryRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::GetOrderHistoryRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_order_history(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::GetOrderHistoryResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_READ_SERVICE_GET_ORDER_HISTORY_SPEC)
            .route_view(
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetUserTrades",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::GetUserTradesRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::GetUserTradesRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_user_trades(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::GetUserTradesResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_READ_SERVICE_GET_USER_TRADES_SPEC)
            .route_view(
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetOrder",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::GetOrderRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::GetOrderRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_order(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::GetOrderResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_READ_SERVICE_GET_ORDER_SPEC)
            .route_view(
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetBatchReplaceStatus",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::orders::v1::GetBatchReplaceStatusRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_batch_replace_status(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::orders::v1::GetBatchReplaceStatusResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(ORDERS_READ_SERVICE_GET_BATCH_REPLACE_STATUS_SPEC)
    }
}
/// Type-inference marker used by [`Router::add_service`](::connectrpc::Router::add_service).
#[doc(hidden)]
pub struct OrdersReadServiceRegisterMarker;
impl<S: OrdersReadService> ::connectrpc::ServiceRegister<OrdersReadServiceRegisterMarker>
for ::std::sync::Arc<S> {
    fn register_service(self, router: ::connectrpc::Router) -> ::connectrpc::Router {
        <S as OrdersReadServiceExt>::register(self, router)
    }
}
/// Monomorphic dispatcher for `OrdersReadService`.
///
/// Unlike `.register(Router)` which type-erases each method into an `Arc<dyn ErasedHandler>` stored in a `HashMap`, this struct dispatches via a compile-time `match` on method name: no vtable, no hash lookup.
///
/// # Example
///
/// ```rust,ignore
/// use connectrpc::ConnectRpcService;
///
/// let server = OrdersReadServiceServer::new(MyImpl);
/// let service = ConnectRpcService::new(server);
/// // hand `service` to axum/hyper as a fallback_service
/// ```
pub struct OrdersReadServiceServer<T> {
    inner: ::std::sync::Arc<T>,
}
impl<T: OrdersReadService> OrdersReadServiceServer<T> {
    /// Wrap a service implementation in a monomorphic dispatcher.
    pub fn new(service: T) -> Self {
        Self {
            inner: ::std::sync::Arc::new(service),
        }
    }
    /// Wrap an already-`Arc`'d service implementation.
    pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
        Self { inner }
    }
}
impl<T> Clone for OrdersReadServiceServer<T> {
    fn clone(&self) -> Self {
        Self {
            inner: ::std::sync::Arc::clone(&self.inner),
        }
    }
}
impl<T: OrdersReadService> ::connectrpc::Dispatcher for OrdersReadServiceServer<T> {
    #[inline]
    fn lookup(
        &self,
        path: &str,
    ) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
        let method = path.strip_prefix("orders.v1.OrdersReadService/")?;
        match method {
            "GetOpenOrders" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_READ_SERVICE_GET_OPEN_ORDERS_SPEC),
                )
            }
            "GetOrderHistory" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_READ_SERVICE_GET_ORDER_HISTORY_SPEC),
                )
            }
            "GetUserTrades" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_READ_SERVICE_GET_USER_TRADES_SPEC),
                )
            }
            "GetOrder" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_READ_SERVICE_GET_ORDER_SPEC),
                )
            }
            "GetBatchReplaceStatus" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(ORDERS_READ_SERVICE_GET_BATCH_REPLACE_STATUS_SPEC),
                )
            }
            _ => None,
        }
    }
    fn call_unary(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::Payload,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            "GetOpenOrders" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::GetOpenOrdersRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::GetOpenOrdersRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::GetOpenOrdersRequest,
                    >::from_parts(&req, &body);
                    svc.get_open_orders(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::GetOpenOrdersResponse,
                        >(format)
                })
            }
            "GetOrderHistory" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::GetOrderHistoryRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::GetOrderHistoryRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::GetOrderHistoryRequest,
                    >::from_parts(&req, &body);
                    svc.get_order_history(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::GetOrderHistoryResponse,
                        >(format)
                })
            }
            "GetUserTrades" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::GetUserTradesRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::GetUserTradesRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::GetUserTradesRequest,
                    >::from_parts(&req, &body);
                    svc.get_user_trades(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::GetUserTradesResponse,
                        >(format)
                })
            }
            "GetOrder" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::GetOrderRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::GetOrderRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::GetOrderRequest,
                    >::from_parts(&req, &body);
                    svc.get_order(ctx, req)
                        .await?
                        .encode::<crate::proto::orders::v1::GetOrderResponse>(format)
                })
            }
            "GetBatchReplaceStatus" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::orders::v1::GetBatchReplaceStatusRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::orders::v1::GetBatchReplaceStatusRequest,
                    >::from_parts(&req, &body);
                    svc.get_batch_replace_status(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::orders::v1::GetBatchReplaceStatusResponse,
                        >(format)
                })
            }
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_server_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::buffa::bytes::Bytes,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
    fn call_client_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_bidi_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("orders.v1.OrdersReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
}
/// Client for this service.
///
/// Generic over `T: ClientTransport`. For **gRPC** (HTTP/2), use
/// `Http2Connection` — it has honest `poll_ready` and composes with
/// `tower::balance` for multi-connection load balancing. For **Connect
/// over HTTP/1.1** (or unknown protocol), use `HttpClient`.
///
/// # Working with the response
///
/// Unary calls return [`UnaryResponse<OwnedView<FooView>>`](::connectrpc::client::UnaryResponse).
/// [`view()`](::connectrpc::client::UnaryResponse::view) borrows the response
/// message, so field access is zero-copy:
///
/// ```rust,ignore
/// let resp = client.get_open_orders(request).await?;
/// let name: &str = resp.view().name;  // borrow into the response buffer
/// ```
///
/// If you need the owned struct (e.g. to store or pass by value), use
/// [`into_owned()`](::connectrpc::client::UnaryResponse::into_owned):
///
/// ```rust,ignore
/// let owned = client.get_open_orders(request).await?.into_owned();
/// ```
///
/// [`into_view()`](::connectrpc::client::UnaryResponse::into_view) keeps the
/// zero-copy decoded body (an `OwnedView`) without copying; field access on it
/// goes through `.reborrow()`. Streaming responses yield one
/// [`StreamMessage`](::connectrpc::StreamMessage) per received message from
/// `.message().await` — read fields zero-copy through the generated accessor
/// methods (`msg.name()`) or `.view()`, or convert with `.to_owned_message()`.
#[derive(Clone)]
pub struct OrdersReadServiceClient<T> {
    transport: T,
    config: ::connectrpc::client::ClientConfig,
}
impl<T> OrdersReadServiceClient<T>
where
    T: ::connectrpc::client::ClientTransport,
    <T::ResponseBody as ::connectrpc::http_body::Body>::Error: ::std::fmt::Display,
{
    /// Create a new client with the given transport and configuration.
    pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
        Self { transport, config }
    }
    /// Get the client configuration.
    pub fn config(&self) -> &::connectrpc::client::ClientConfig {
        &self.config
    }
    /// Get a mutable reference to the client configuration.
    pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
        &mut self.config
    }
    /// Call the GetOpenOrders RPC. Sends a request to /orders.v1.OrdersReadService/GetOpenOrders.
    pub async fn get_open_orders(
        &self,
        request: crate::proto::orders::v1::GetOpenOrdersRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetOpenOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_open_orders_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetOpenOrders RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_open_orders_with_options(
        &self,
        request: crate::proto::orders::v1::GetOpenOrdersRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetOpenOrdersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetOpenOrders",
                request,
                options,
            )
            .await
    }
    /// Call the GetOrderHistory RPC. Sends a request to /orders.v1.OrdersReadService/GetOrderHistory.
    pub async fn get_order_history(
        &self,
        request: crate::proto::orders::v1::GetOrderHistoryRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetOrderHistoryResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_order_history_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetOrderHistory RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_order_history_with_options(
        &self,
        request: crate::proto::orders::v1::GetOrderHistoryRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetOrderHistoryResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetOrderHistory",
                request,
                options,
            )
            .await
    }
    /// Call the GetUserTrades RPC. Sends a request to /orders.v1.OrdersReadService/GetUserTrades.
    pub async fn get_user_trades(
        &self,
        request: crate::proto::orders::v1::GetUserTradesRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetUserTradesResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_user_trades_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetUserTrades RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_user_trades_with_options(
        &self,
        request: crate::proto::orders::v1::GetUserTradesRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetUserTradesResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetUserTrades",
                request,
                options,
            )
            .await
    }
    /// Call the GetOrder RPC. Sends a request to /orders.v1.OrdersReadService/GetOrder.
    pub async fn get_order(
        &self,
        request: crate::proto::orders::v1::GetOrderRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_order_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetOrder RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_order_with_options(
        &self,
        request: crate::proto::orders::v1::GetOrderRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetOrderResponseView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetOrder",
                request,
                options,
            )
            .await
    }
    /// Call the GetBatchReplaceStatus RPC. Sends a request to /orders.v1.OrdersReadService/GetBatchReplaceStatus.
    pub async fn get_batch_replace_status(
        &self,
        request: crate::proto::orders::v1::GetBatchReplaceStatusRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_batch_replace_status_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetBatchReplaceStatus RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_batch_replace_status_with_options(
        &self,
        request: crate::proto::orders::v1::GetBatchReplaceStatusRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::orders::v1::__buffa::view::GetBatchReplaceStatusResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                ORDERS_READ_SERVICE_SERVICE_NAME,
                "GetBatchReplaceStatus",
                request,
                options,
            )
            .await
    }
}