Commit 0be36f71 authored by Him188's avatar Him188

More useful `.incoming`

parent 94f6af56
...@@ -129,9 +129,11 @@ inline fun <R> Bot.subscribeFriendMessages(crossinline listeners: MessageSubscri ...@@ -129,9 +129,11 @@ inline fun <R> Bot.subscribeFriendMessages(crossinline listeners: MessageSubscri
/** /**
* 返回一个指定事件的接收通道 * 返回一个指定事件的接收通道
*
* @param capacity 同 [Channel] 的参数, 参见 [Channel.Factory] 中的常量.
*/ */
inline fun <reified E : Event> Bot.incoming(): ReceiveChannel<E> { inline fun <reified E : Event> CoroutineScope.incoming(capacity: Int = Channel.RENDEZVOUS): ReceiveChannel<E> {
return Channel<E>(8).apply { return Channel<E>(capacity).apply {
subscribeAlways<E> { subscribeAlways<E> {
send(this) send(this)
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment