Skip to content

Commit 69136d3

Browse files
Rename -> .
1 parent ed244f6 commit 69136d3

File tree

9 files changed

+23
-20
lines changed

9 files changed

+23
-20
lines changed

context/getting-started.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ $ bundle add protocol-grpc async-http
2323
- {ruby Async::GRPC::Client} - An asynchronous gRPC client that wraps `Async::HTTP::Client`.
2424
- {ruby Async::GRPC::Stub} - A method-based stub for making RPC calls.
2525
- {ruby Async::GRPC::Service} - A concrete service implementation that uses a `Protocol::GRPC::Interface`.
26-
- {ruby Async::GRPC::DispatcherMiddleware} - Middleware that routes requests to registered services.
26+
- {ruby Async::GRPC::Dispatcher} - Middleware that routes requests to registered services.
2727

2828
## Client Usage
2929

@@ -104,9 +104,9 @@ end
104104
### Registering Services
105105

106106
``` ruby
107-
require "async/grpc/dispatcher_middleware"
107+
require "async/grpc/dispatcher"
108108

109-
dispatcher = Async::GRPC::DispatcherMiddleware.new
109+
dispatcher = Async::GRPC::Dispatcher.new
110110

111111
service = GreeterService.new(GreeterInterface, "hello.Greeter")
112112
dispatcher.register(service)
@@ -151,7 +151,7 @@ end
151151
Async do
152152
# Setup server
153153
endpoint = Async::HTTP::Endpoint.parse("http://localhost:50051")
154-
dispatcher = Async::GRPC::DispatcherMiddleware.new
154+
dispatcher = Async::GRPC::Dispatcher.new
155155
dispatcher.register(GreeterService.new(GreeterInterface, "hello.Greeter"))
156156
server = Async::HTTP::Server.for(endpoint, dispatcher)
157157

guides/getting-started/readme.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ $ bundle add protocol-grpc async-http
2323
- {ruby Async::GRPC::Client} - An asynchronous gRPC client that wraps `Async::HTTP::Client`.
2424
- {ruby Async::GRPC::Stub} - A method-based stub for making RPC calls.
2525
- {ruby Async::GRPC::Service} - A concrete service implementation that uses a `Protocol::GRPC::Interface`.
26-
- {ruby Async::GRPC::DispatcherMiddleware} - Middleware that routes requests to registered services.
26+
- {ruby Async::GRPC::Dispatcher} - Middleware that routes requests to registered services.
2727

2828
## Client Usage
2929

@@ -104,9 +104,9 @@ end
104104
### Registering Services
105105

106106
``` ruby
107-
require "async/grpc/dispatcher_middleware"
107+
require "async/grpc/dispatcher"
108108

109-
dispatcher = Async::GRPC::DispatcherMiddleware.new
109+
dispatcher = Async::GRPC::Dispatcher.new
110110

111111
service = GreeterService.new(GreeterInterface, "hello.Greeter")
112112
dispatcher.register(service)
@@ -151,7 +151,7 @@ end
151151
Async do
152152
# Setup server
153153
endpoint = Async::HTTP::Endpoint.parse("http://localhost:50051")
154-
dispatcher = Async::GRPC::DispatcherMiddleware.new
154+
dispatcher = Async::GRPC::Dispatcher.new
155155
dispatcher.register(GreeterService.new(GreeterInterface, "hello.Greeter"))
156156
server = Async::HTTP::Server.for(endpoint, dispatcher)
157157

lib/async/grpc.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
require_relative "grpc/client"
88
require_relative "grpc/service"
99
require_relative "grpc/stub"
10-
require_relative "grpc/dispatcher_middleware"
10+
require_relative "grpc/dispatcher"
1111

1212
module Async
1313
module GRPC
Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,16 +17,16 @@
1717

1818
module Async
1919
module GRPC
20-
# Represents middleware that dispatches gRPC requests to registered services.
20+
# Dispatches gRPC requests to registered services.
2121
# Handles routing based on service name from the request path.
2222
#
2323
# @example Registering services:
24-
# dispatcher = DispatcherMiddleware.new
24+
# dispatcher = Dispatcher.new
2525
# dispatcher.register(GreeterService.new(GreeterInterface, "hello.Greeter"))
2626
# dispatcher.register(WorldService.new(WorldInterface, "world.Greeter"))
2727
#
2828
# server = Async::HTTP::Server.for(endpoint, dispatcher)
29-
class DispatcherMiddleware < Protocol::GRPC::Middleware
29+
class Dispatcher < Protocol::GRPC::Middleware
3030
# Initialize the dispatcher.
3131
# @parameter app [#call | Nil] The next middleware in the chain
3232
# @parameter services [Hash] Optional initial services hash (service_name => service_instance)
@@ -146,3 +146,4 @@ def dispatch(request)
146146
end
147147
end
148148
end
149+

lib/async/grpc/service.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ module Async
99
module GRPC
1010
# Represents a concrete service implementation that uses an Interface.
1111
# Subclass this and implement the RPC methods defined in the interface.
12-
# Services are registered with DispatcherMiddleware for routing.
12+
# Services are registered with Dispatcher for routing.
1313
#
1414
# @example Example service implementation:
1515
# class GreeterInterface < Protocol::GRPC::Interface
@@ -32,7 +32,7 @@ module GRPC
3232
# end
3333
#
3434
# # Register with dispatcher:
35-
# dispatcher = DispatcherMiddleware.new
35+
# dispatcher = Dispatcher.new
3636
# dispatcher.register(GreeterService.new(GreeterInterface, "hello.Greeter"))
3737
# server = Async::HTTP::Server.for(endpoint, dispatcher)
3838
class Service

readme.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ Asynchronous gRPC client and server implementation built on top of `protocol-grp
1010

1111
- **Asynchronous client** - Wraps `Async::HTTP::Client` to provide gRPC-specific call methods with automatic message framing and status handling.
1212
- **Method-based stubs** - Create type-safe stubs from `Protocol::GRPC::Interface` definitions. Accepts both PascalCase and snake\_case method names for convenience.
13-
- **Server middleware** - `DispatcherMiddleware` routes requests to registered services based on path.
13+
- **Server middleware** - `Dispatcher` routes requests to registered services based on path.
1414
- **All RPC patterns** - Supports unary, server streaming, client streaming, and bidirectional streaming RPCs.
1515
- **HTTP/1 and HTTP/2 transport** - Built on `async-http` with automatic HTTP/2 multiplexing and connection pooling.
1616

releases.md

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,8 @@
22

33
## Unreleased
44

5-
- Simplified `DispatcherMiddleware#register` API to `register(service, name: service.service_name)`, eliminating redundant service name specification.
5+
- Renamed `DispatcherMiddleware` to `Dispatcher` for cleaner API.
6+
- Simplified `Dispatcher#register` API to `register(service, name: service.service_name)`, eliminating redundant service name specification.
67

78
## v0.2.0
89

test/async/grpc/client.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
AClient = Sus::Shared("a client") do
1616
let(:service_name) {"test.Service"}
1717
let(:service) {Async::GRPC::Fixtures::TestService.new(Async::GRPC::Fixtures::TestInterface, service_name)}
18-
let(:dispatcher) {Async::GRPC::DispatcherMiddleware.new(services: { service_name => service })}
18+
let(:dispatcher) {Async::GRPC::Dispatcher.new(services: { service_name => service })}
1919
let(:app) {dispatcher}
2020

2121
it "can make unary RPC call" do
@@ -119,7 +119,7 @@
119119
end
120120
end.new(error_interface_class, error_service_name)
121121
end
122-
let(:app) {Async::GRPC::DispatcherMiddleware.new(services: { error_service_name => error_service })}
122+
let(:app) {Async::GRPC::Dispatcher.new(services: { error_service_name => error_service })}
123123

124124
it "raises Protocol::GRPC::Error with correct status code" do
125125
grpc_client = Async::GRPC::Client.new(client)
Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,14 +3,14 @@
33
# Released under the MIT License.
44
# Copyright, 2025, by Samuel Williams.
55

6-
require "async/grpc/dispatcher_middleware"
6+
require "async/grpc/dispatcher"
77
require "async/grpc/service"
88
require "protocol/http"
99
require "protocol/grpc/methods"
1010
require "protocol/grpc/body/writable_body"
1111
require "async/grpc/test_interface"
1212

13-
describe Async::GRPC::DispatcherMiddleware do
13+
describe Async::GRPC::Dispatcher do
1414
include Sus::Fixtures::Async::SchedulerContext
1515

1616
let(:service_name) {"test.Service"}
@@ -104,3 +104,4 @@
104104
end
105105
end
106106
end
107+

0 commit comments

Comments
 (0)