|
@@ -269,7 +269,7 @@ extension GRPCChannel {
|
|
|
descriptor: MethodDescriptor,
|
|
descriptor: MethodDescriptor,
|
|
|
options: CallOptions
|
|
options: CallOptions
|
|
|
) async -> MakeStreamResult {
|
|
) async -> MakeStreamResult {
|
|
|
- let waitForReady = options.waitForReady ?? true
|
|
|
|
|
|
|
+ let waitForReady = options.waitForReady ?? false
|
|
|
switch self.state.withLock({ $0.makeStream(waitForReady: waitForReady) }) {
|
|
switch self.state.withLock({ $0.makeStream(waitForReady: waitForReady) }) {
|
|
|
case .useLoadBalancer(let loadBalancer):
|
|
case .useLoadBalancer(let loadBalancer):
|
|
|
return await self.makeStream(
|
|
return await self.makeStream(
|