import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
IListenerAdaptor(EventDispatcher dispatcher) {
	this.dispatcher = dispatcher;
	dispatcher.registerListener(new IListener() {
		@Override
		public void handle(Event event) {
			emitters.forEach(emitter -> emitter.onNext(event));
		}
	});
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
IListenerAdaptor(EventDispatcher dispatcher) {
	this.dispatcher = dispatcher;
	dispatcher.registerListener(new IListener() {
		@Override
		public void handle(Event event) {
			sinks.forEach(sink -> sink.next(event));
		}
	});
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
/**
 * Creates a new instance of this class.
 *
 * @param client The discord client.
 */
public Discord4JHandler(IDiscordClient client) {
    client.getDispatcher().registerListener(new IListener<MessageReceivedEvent> () {
        @Override
        public void handle(MessageReceivedEvent event) {
            handleMessageCreate(event);
        }
    });
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
/**
 * Register this listener for Discord4J events
 *
 * @param listener the discord event listener
 */
public void subscribe(IListener<?> listener) {
    if (client != null && client.isReady()) {
        log.debug("Subscribing {}", listener.getClass().getCanonicalName());
        client.getDispatcher().registerListener(listener);
    }
    queuedListeners.add(listener);
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
private <T extends IReceiver & IListener<? extends Event>> void registerListener(@NotNull T eventListener) {
    discordClient.getDispatcher().registerListener(eventListener);
    eventListeners.add(eventListener);
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
@Override
public List<IListener<?>> getListeners() {
    return Collections.singletonList(this);
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
public void unsubscribe(IListener<?> listener) {
    client.getDispatcher().unregisterListener(listener);
    queuedListeners.remove(listener);
}
 

import sx.blah.discord.api.events.IListener; //导入依赖的package包/类
List<IListener<?>> getListeners();