Review

packages/docprovider/src/awareness.ts

@@ -6,7 +6,6 @@
 import { User } from '@jupyterlab/services';
 
 import { IDisposable } from '@lumino/disposable';
-import { IStream, Stream } from '@lumino/signaling';
 
 import { IAwareness } from '@jupyter/ydoc';
 
@@ -17,12 +16,6 @@ export interface IContent {
   body: string;
 }
 
-export interface IChatMessage {
-  sender: string;
-  timestamp: number;
-  content: IContent;
-}
-
 /**
  * A class to provide Yjs synchronization over WebSocket.
  *
@@ -50,21 +43,12 @@ export class WebSocketAwarenessProvider
       .then(() => this._onUserChanged(this._user))
       .catch(e => console.error(e));
     this._user.userChanged.connect(this._onUserChanged, this);
-
-    this._messageStream = new Stream(this);
   }
 
   get isDisposed(): boolean {
     return this._isDisposed;
   }
 
-  /**
-   * A signal to subscribe for incoming messages.
-   */
-  get messageStream(): IStream<this, IChatMessage> {
-    return this._messageStream;
-  }
-
   dispose(): void {
     if (this._isDisposed) {
       return;
@@ -82,8 +66,6 @@ export class WebSocketAwarenessProvider
   private _isDisposed = false;
   private _user: User.IManager;
   private _awareness: IAwareness;
-
-  private _messageStream: Stream<this, IChatMessage>;
 }
 
 /**