rename oneway dispatcher, fix comment

internal/crossdock/client/dispatcher/dispatcher.go

@@ -76,9 +76,9 @@ func Create(t crossdock.T) yarpc.Dispatcher {
 	})
 }
 
-// CreateOneway returns a started dispatcher and returns the address the
+// CreateOnewayDispatcher returns a started dispatcher and returns the address the
 // server should call back to (ie this host)
-func CreateOneway(t crossdock.T, handler raw.OnewayHandler) (yarpc.Dispatcher, string) {
+func CreateOnewayDispatcher(t crossdock.T, handler raw.OnewayHandler) (yarpc.Dispatcher, string) {
 	fatals := crossdock.Fatals(t)
 
 	server := t.Param("server_oneway")

internal/crossdock/client/dispatcher/dispatcher_test.go

@@ -103,7 +103,7 @@ func TestCreateOneway(t *testing.T) {
 
 	for _, tt := range tests {
 		entries := crossdock.Run(tt.params, func(ct crossdock.T) {
-			dispatcher, callBackAddr := CreateOneway(ct, nil)
+			dispatcher, callBackAddr := CreateOnewayDispatcher(ct, nil)
 
 			// should get here only if the request succeeded
 			clientConfig := dispatcher.ClientConfig("yarpc-test")

internal/crossdock/client/oneway/oneway.go

@@ -35,7 +35,7 @@ import (
 // Run starts the oneway behavior, testing a combination of encodings and transports
 func Run(t crossdock.T) {
 	callBackHandler, serverCalledBack := newCallBackHandler()
-	dispatcher, callBackAddr := dispatcher.CreateOneway(t, callBackHandler)
+	dispatcher, callBackAddr := dispatcher.CreateOnewayDispatcher(t, callBackHandler)
 	defer dispatcher.Stop()
 
 	encoding := t.Param(params.Encoding)
@@ -51,8 +51,7 @@ func Run(t crossdock.T) {
 	}
 }
 
-// newCallBackHandler creates a oneway handler that fills a channel
-// with the received body
+// newCallBackHandler creates a oneway handler that fills a channel with the body
 func newCallBackHandler() (raw.OnewayHandler, <-chan []byte) {
 	serverCalledBack := make(chan []byte)
 	handler := func(ctx context.Context, reqMeta yarpc.ReqMeta, body []byte) error {