This commit is contained in:
syuilo 2017-11-16 23:46:54 +09:00
parent afc486c031
commit 4129dce95a
2 changed files with 5 additions and 5 deletions

View file

@ -3,7 +3,7 @@ import * as riot from 'riot';
import MiOS from './mios'; import MiOS from './mios';
import ServerStreamManager from './scripts/server-stream-manager'; import ServerStreamManager from './scripts/server-stream-manager';
import RequestsStreamManager from './scripts/requests-stream-manager'; import RequestsStreamManager from './scripts/requests-stream-manager';
import MessagingIndexStream from './scripts/messaging-index-stream-manager'; import MessagingIndexStreamManager from './scripts/messaging-index-stream-manager';
import DriveStreamManager from './scripts/drive-stream-manager'; import DriveStreamManager from './scripts/drive-stream-manager';
export default (mios: MiOS) => { export default (mios: MiOS) => {
@ -31,10 +31,10 @@ export default (mios: MiOS) => {
(riot as any).mixin('api', { (riot as any).mixin('api', {
api: mios.api api: mios.api
}); });
(riot as any).mixin('drive-stream', { driveStream: new DriveStreamManager(mios.i) });
(riot as any).mixin('stream', { stream: mios.stream });
(riot as any).mixin('stream', { stream: mios.stream });
(riot as any).mixin('drive-stream', { driveStream: new DriveStreamManager(mios.i) });
(riot as any).mixin('server-stream', { serverStream: new ServerStreamManager() }); (riot as any).mixin('server-stream', { serverStream: new ServerStreamManager() });
(riot as any).mixin('requests-stream', { requestsStream: new RequestsStreamManager() }); (riot as any).mixin('requests-stream', { requestsStream: new RequestsStreamManager() });
(riot as any).mixin('messaging-index-stream', { messagingIndexStream: new MessagingIndexStream(mios.i) }); (riot as any).mixin('messaging-index-stream', { messagingIndexStream: new MessagingIndexStreamManager(mios.i) });
}; };

View file

@ -1,7 +1,7 @@
import StreamManager from './stream-manager'; import StreamManager from './stream-manager';
import Connection from './messaging-index-stream'; import Connection from './messaging-index-stream';
export default class ServerStreamManager extends StreamManager<Connection> { export default class MessagingIndexStreamManager extends StreamManager<Connection> {
private me; private me;
constructor(me) { constructor(me) {