Tonic build error - The trait Service<tonic::Request<Streaming<_>>> is not implemented for MessageQueueSvc<T>

[Stay1444]

Hello. I'm encountering a build error in the source files auto generated by tonic.

The error that I'm getting:

error[E0277]: the trait bound `MessageQueueSvc<T>: Service<tonic::Request<Streaming<_>>>` is not satisfied
   --> /home/stay/Projects/ferret/ferret-cnc/target/debug/build/ferret-cnc-35bc60b4789ca2d7/out/ferret.rs:348:40
    |
348 |                         let res = grpc.streaming(method, req).await;
    |                                        ^^^^^^^^^ the trait `Service<tonic::Request<Streaming<_>>>` is not implemented for `MessageQueueSvc<T>`
    |
    = help: the following other types implement trait `Service<Request>`:
              <&'a mut S as Service<Request>>
              <&hyper::client::client::Client<C, B> as Service<axum::http::Request<B>>>
              <AddExtension<S, T> as Service<axum::http::Request<ResBody>>>
              <Box<S> as Service<Request>>
              <Channel as Service<axum::http::Request<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, Status>>>>
              <CoreServer<T> as Service<axum::http::Request<B>>>
              <FromExtractor<T, E, S> as Service<axum::http::Request<B>>>
              <HandleError<S, F, ()> as Service<axum::http::Request<B>>>
            and 111 others
    = note: required for `MessageQueueSvc<T>` to implement `StreamingService<_>`

error[E0277]: the trait bound `MessageQueueSvc<T>: Service<tonic::Request<Streaming<_>>>` is not satisfied
   --> /home/stay/Projects/ferret/ferret-cnc/target/debug/build/ferret-cnc-35bc60b4789ca2d7/out/ferret.rs:348:50
    |
348 |                         let res = grpc.streaming(method, req).await;
    |                                        --------- ^^^^^^ the trait `Service<tonic::Request<Streaming<_>>>` is not implemented for `MessageQueueSvc<T>`
    |                                        |
    |                                        required by a bound introduced by this call
    |
    = help: the following other types implement trait `Service<Request>`:
              <&'a mut S as Service<Request>>
              <&hyper::client::client::Client<C, B> as Service<axum::http::Request<B>>>
              <AddExtension<S, T> as Service<axum::http::Request<ResBody>>>
              <Box<S> as Service<Request>>
              <Channel as Service<axum::http::Request<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, Status>>>>
              <CoreServer<T> as Service<axum::http::Request<B>>>
              <FromExtractor<T, E, S> as Service<axum::http::Request<B>>>
              <HandleError<S, F, ()> as Service<axum::http::Request<B>>>
            and 111 others
    = note: required for `MessageQueueSvc<T>` to implement `StreamingService<_>`
note: required by a bound in `tonic::server::Grpc::<T>::streaming`
   --> /home/stay/.cargo/registry/src/index.crates.io-6f17d22bba15001f/tonic-0.9.2/src/server/grpc.rs:346:12
    |
340 |     pub async fn streaming<S, B>(
    |                  --------- required by a bound in this associated function
...
346 |         S: StreamingService<T::Decode, Response = T::Encode> + Send,
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `Grpc::<T>::streaming`

My build.rs:

fn main() {
    tonic_build::configure()
        .build_server(true)
        .build_transport(true)
        .compile(&[
            "../ferret-proto/core.proto",
            "../ferret-proto/entities/os.proto",
            "../ferret-proto/messages/client_messages.proto",
            "../ferret-proto/messages/server_messages.proto"
        ], &[
            "../ferret-proto/",
            "../ferret-proto/entities",
            "../ferret-proto/messages"
        ])
        .unwrap();
}

core.proto

syntax = "proto3";

package ferret;

import "entities/os.proto";

import "messages/client_messages.proto";
import "messages/server_messages.proto";

service Core {
  rpc Handshake(HandshakeRequest) returns (HandshakeResponse);
  rpc MessageQueue(stream ferret.messages.client.ClientMessage) returns (stream ferret.messages.server.ServerMessage);
}

message HandshakeRequest {
  string Id = 1;
  ferret.entities.OS System = 2;
  string Hostname = 3;
}

message HandshakeResponse {}

messages/client_messages.proto

syntax = "proto3";

package ferret.messages.client;

message ClientMessage {
    oneof Message {
        ScreenData ScreenData = 1;
        ResourcesData ResourcesData = 2;
        ShellDied ShellDied = 3;
        ShellOpenResult ShellOpenResult = 4;
        ShellData ShellData = 5;
    }
}

message ScreenData {
    bytes Data = 1;
}

message ResourcesData {

}

message ShellDied {
    int32 ShellId = 1; 
}

message ShellOpenResult {
    bool Success = 1;
}

message ShellData {
    int32 ShellId = 1;
    string Data = 2;
}

rpc.rs

tonic::include_proto!("ferret");
tonic::include_proto!("ferret.entities");
tonic::include_proto!("ferret.messages.client");
tonic::include_proto!("ferret.messages.server");

(Server messages is basically the same).

I suspect that it has something to do with oneof. Any idea?

[michaelhaig]

What version of tonic are you using in Cargo.toml?
I had similar issues when I used

tonic = "0.11"

as a dependency, rather than

tonic = "0.2"

I haven't worked out how to fix the problem, so I am stuck using version 0.2 of tonic.

Any further comments from the Rust community welcome.

[PedroRosalba]

anyone's got a solution for this? also stuck in same error

[michaelhaig]

tonic-problem.zip

This builds OK with rustc version 1.84
(Noting that I shoved all the .proto defs into one file and set up the Cargo.toml with the latest and greatest crate versions of everything needed to compile.
Hope this helps.