@@ -191,9 +191,7 @@ class CompanionObjectGenerator(
191
191
def _bindService[F[_]](
192
192
compressionType: _root_.higherkindness.mu.rpc.protocol.CompressionType
193
193
)(
194
- $implicitOrUsingCE, ${implicitOrUsing(
195
- param " algebra: $serviceTypeName[F] "
196
- )}
194
+ $implicitOrUsingCE, ${param " algebra: $serviceTypeName[F] " }
197
195
): _root_.cats.effect.Resource[F, _root_.io.grpc.ServerServiceDefinition] =
198
196
_root_.cats.effect.std.Dispatcher.parallel[F].evalMap { disp =>
199
197
_root_.higherkindness.mu.rpc.internal.service.GRPCServiceDefBuilder.build[F](
@@ -211,9 +209,10 @@ class CompanionObjectGenerator(
211
209
}
212
210
213
211
q """
214
- def bindService[F[_]]( $implicitOrUsingCE, ${implicitOrUsing(
215
- param " algebra: $serviceTypeName[F] "
216
- )}): _root_.cats.effect.Resource[F, _root_.io.grpc.ServerServiceDefinition] =
212
+ def bindService[F[_]](
213
+ $implicitOrUsingCE,
214
+ ${param " algebra: $serviceTypeName[F] " }
215
+ ): _root_.cats.effect.Resource[F, _root_.io.grpc.ServerServiceDefinition] =
217
216
_bindService[F]( $compression)
218
217
"""
219
218
}
@@ -271,10 +270,8 @@ class CompanionObjectGenerator(
271
270
compressionType: _root_.higherkindness.mu.rpc.protocol.CompressionType
272
271
)(
273
272
$implicitOrUsingCE,
274
- ${implicitOrUsing(
275
- param " serverContext: _root_.higherkindness.mu.rpc.internal.context.ServerContext[F, Context] "
276
- )},
277
- ${implicitOrUsing(param " algebra: $serviceTypeName[ $kleisliTypeLambda] " )}
273
+ ${param " serverContext: _root_.higherkindness.mu.rpc.internal.context.ServerContext[F, Context] " },
274
+ ${param " algebra: $serviceTypeName[ $kleisliTypeLambda] " }
278
275
): _root_.cats.effect.Resource[F, _root_.io.grpc.ServerServiceDefinition] =
279
276
_root_.cats.effect.std.Dispatcher.parallel[F].evalMap { disp =>
280
277
_root_.higherkindness.mu.rpc.internal.service.GRPCServiceDefBuilder.build[F](
@@ -294,10 +291,8 @@ class CompanionObjectGenerator(
294
291
q """
295
292
def bindContextService[F[_], Context](
296
293
$implicitOrUsingCE,
297
- ${implicitOrUsing(
298
- param " serverContext: _root_.higherkindness.mu.rpc.internal.context.ServerContext[F, Context] "
299
- )},
300
- ${implicitOrUsing(param " algebra: $serviceTypeName[ $kleisliTypeLambda] " )}
294
+ ${param " serverContext: _root_.higherkindness.mu.rpc.internal.context.ServerContext[F, Context] " },
295
+ ${param " algebra: $serviceTypeName[ $kleisliTypeLambda] " }
301
296
): _root_.cats.effect.Resource[F, _root_.io.grpc.ServerServiceDefinition] =
302
297
_bindContextService[F, Context]( $compression)
303
298
"""
@@ -494,9 +489,7 @@ class CompanionObjectGenerator(
494
489
options: _root_.io.grpc.CallOptions = _root_.io.grpc.CallOptions.DEFAULT
495
490
)(
496
491
$implicitOrUsingCE,
497
- ${implicitOrUsing(
498
- param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] "
499
- )}
492
+ ${param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] " }
500
493
) extends _root_.io.grpc.stub.AbstractStub[ContextClient[F, Context]](channel, options)
501
494
with ( $serviceTypeName[ $kleisliTypeLambda]) {
502
495
@@ -520,9 +513,7 @@ class CompanionObjectGenerator(
520
513
options: _root_.io.grpc.CallOptions = _root_.io.grpc.CallOptions.DEFAULT
521
514
)(
522
515
$implicitOrUsingCE,
523
- ${implicitOrUsing(
524
- param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] "
525
- )}
516
+ ${param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] " }
526
517
): _root_.cats.effect.Resource[F, $serviceTypeName[ $kleisliTypeLambda]] =
527
518
_root_.cats.effect.Resource.make(
528
519
new _root_.higherkindness.mu.rpc.channel.ManagedChannelInterpreter[F](channelFor, channelConfigList).build
@@ -540,9 +531,7 @@ class CompanionObjectGenerator(
540
531
options: _root_.io.grpc.CallOptions = _root_.io.grpc.CallOptions.DEFAULT
541
532
)(
542
533
$implicitOrUsingCE,
543
- ${implicitOrUsing(
544
- param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] "
545
- )}
534
+ ${param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] " }
546
535
): _root_.cats.effect.Resource[F, $serviceTypeName[ $kleisliTypeLambda]] =
547
536
_root_.cats.effect.Resource.make(channel)(
548
537
(channel) => CE.void(CE.delay(channel.shutdown()))
@@ -560,9 +549,7 @@ class CompanionObjectGenerator(
560
549
options: _root_.io.grpc.CallOptions = _root_.io.grpc.CallOptions.DEFAULT
561
550
)(
562
551
$implicitOrUsingCE,
563
- ${implicitOrUsing(
564
- param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] "
565
- )}
552
+ ${param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] " }
566
553
): $serviceTypeName[ $kleisliTypeLambda] = {
567
554
val managedChannelInterpreter = new _root_.higherkindness.mu.rpc.channel.ManagedChannelInterpreter[F](channelFor, channelConfigList).unsafeBuild(disp)
568
555
new ContextClient[F, Context](managedChannelInterpreter, options)
@@ -576,9 +563,7 @@ class CompanionObjectGenerator(
576
563
options: _root_.io.grpc.CallOptions = _root_.io.grpc.CallOptions.DEFAULT
577
564
)(
578
565
$implicitOrUsingCE,
579
- ${implicitOrUsing(
580
- param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] "
581
- )}
566
+ ${param " clientContext: _root_.higherkindness.mu.rpc.internal.context.ClientContext[F, Context] " }
582
567
): $serviceTypeName[ $kleisliTypeLambda] =
583
568
new ContextClient[F, Context](channel, options)
584
569
"""
0 commit comments