| 1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- /*
- * Copyright 2024, gRPC Authors All rights reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
- import ArgumentParser
- import GRPCCore
- import GRPCNIOTransportHTTP2
- struct Get: AsyncParsableCommand {
- static let configuration = CommandConfiguration(abstract: "Makes a unary RPC to the echo server.")
- @OptionGroup
- var arguments: ClientArguments
- func run() async throws {
- try await withGRPCClient(
- transport: .http2NIOPosix(
- target: self.arguments.target,
- transportSecurity: .plaintext
- )
- ) { client in
- let echo = Echo_Echo.Client(wrapping: client)
- for _ in 0 ..< self.arguments.repetitions {
- let message = Echo_EchoRequest.with { $0.text = self.arguments.message }
- print("get → \(message.text)")
- let response = try await echo.get(message)
- print("get ← \(response.text)")
- }
- }
- }
- }
|