Create unbuffered Tumble entry point for LogDog.

logdog/appengine/coordinator/endpoints/services/registerStream_test.go

Index: logdog/appengine/coordinator/endpoints/services/registerStream_test.go
diff --git a/logdog/appengine/coordinator/endpoints/services/registerStream_test.go b/logdog/appengine/coordinator/endpoints/services/registerStream_test.go
index 15474c68170d6a651a45d512a60814ccd5145c7a..1c1b5cef56ab8a06d94b27a85e2523c7ae748fc0 100644
--- a/logdog/appengine/coordinator/endpoints/services/registerStream_test.go
+++ b/logdog/appengine/coordinator/endpoints/services/registerStream_test.go
@@ -300,43 +300,6 @@ func TestRegisterStream(t *testing.T) {
 						So(err, ShouldBeRPCInvalidArgument, "Invalid log stream descriptor")
 					})
 				})
-
-				Convey(`The registerStreamMutation`, func() {
-					svcs := coordinator.GetServices(c)
-					cfg, err := svcs.Config(c)
-					if err != nil {
-						panic(err)
-					}
-					pcfg, err := svcs.ProjectConfig(c, "proj-foo")
-					if err != nil {
-						panic(err)
-					}
-
-					rsm := registerStreamMutation{
-						RegisterStreamRequest: &req,
-
-						cfg:  cfg,
-						pcfg: pcfg,
-
-						desc: tls.Desc,
-						pfx:  tls.Prefix,
-						ls:   tls.Stream,
-						lst:  tls.State,
-					}
-
-					Convey(`Can RollForward.`, func() {
-						_, err := rsm.RollForward(c)
-						So(err, ShouldBeNil)
-					})
-
-					Convey(`Returns internal server error if the stream Put() fails (tumble).`, func() {
-						c, fb := featureBreaker.FilterRDS(c, nil)
-						fb.BreakFeatures(errors.New("test error"), "PutMulti")
-
-						_, err := rsm.RollForward(c)
-						So(err, ShouldBeRPCInternal)
-					})
-				})
 			})
 		})
 	})