Index: third_party/mojo/src/mojo/public/go/bindings/stub.go |
diff --git a/third_party/mojo/src/mojo/public/go/bindings/stub.go b/third_party/mojo/src/mojo/public/go/bindings/stub.go |
deleted file mode 100644 |
index c7ca09f51e6d757fb8fec4bf87369cdd51753d2e..0000000000000000000000000000000000000000 |
--- a/third_party/mojo/src/mojo/public/go/bindings/stub.go |
+++ /dev/null |
@@ -1,63 +0,0 @@ |
-// Copyright 2015 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-package bindings |
- |
-import ( |
- "sync" |
-) |
- |
-// MessageReceiver can receive |Message| objects. |
-type MessageReceiver interface { |
- // Accept receives a |Message|. Returns a error if the message was not |
- // handled. |
- Accept(message *Message) error |
-} |
- |
-// Stub is a base implementation of Stub. Stubs receives messages from message |
-// pipe, deserialize the payload and call the appropriate method in the |
-// implementation. If the method returns result, the stub serializes the |
-// response and sends it back. |
-type Stub struct { |
- // Makes sure that connector is closed only once. |
- closeOnce sync.Once |
- connector *Connector |
- receiver MessageReceiver |
-} |
- |
-// NewStub returns a new Stub instance using provided |Connector| to send and |
-// receive messages. Incoming messages are handled by the provided |receiver|. |
-func NewStub(connector *Connector, receiver MessageReceiver) *Stub { |
- return &Stub{ |
- connector: connector, |
- receiver: receiver, |
- } |
-} |
- |
-// ServeRequest synchronously serves one request from the message pipe: the |
-// |Stub| waits on its underlying message pipe for a message and handles it. |
-// Can be called from multiple goroutines. Each calling goroutine will receive |
-// a different message or an error. Closes itself in case of error. |
-func (s *Stub) ServeRequest() error { |
- message, err := s.connector.ReadMessage() |
- if err != nil { |
- s.Close() |
- return err |
- } |
- err = s.receiver.Accept(message) |
- if err != nil { |
- s.Close() |
- } |
- return err |
-} |
- |
-// Close immediately closes the |Stub| and its underlying message pipe. If the |
-// |Stub| is waiting on its message pipe handle the wait process is interrupted. |
-// All goroutines trying to serve will start returning errors as the underlying |
-// message pipe becomes invalid. |
-func (s *Stub) Close() { |
- s.closeOnce.Do(func() { |
- s.connector.Close() |
- }) |
-} |