mdedetrich commented on PR #146:
URL:
https://github.com/apache/incubator-pekko-connectors/pull/146#issuecomment-1584247846
@pjfanning Ah I noticed the core problem, just use `enqueueAll` instead of
`enqueue`! `ByteString` is actually an iterator/collection and so `enqueueAll`
is what we should be using, the definition of both of these functions should
make it clear
```scala
@deprecated("Use `enqueueAll` instead of `enqueue` to enqueue a collection
of elements", "2.13.0")
@`inline` final def enqueue[B >: A](iter: scala.collection.Iterable[B]) =
enqueueAll(iter)
/** Creates a new queue with all elements provided by an `Iterable` object
* added at the end of the old queue.
*
* The elements are appended in the order they are given out by the
* iterator.
*
* @param iter an iterable object
*/
def enqueueAll[B >: A](iter: scala.collection.Iterable[B]): Queue[B] =
appendedAll(iter)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
