unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/javadsl/UnixDomainSocket.scala (3 lines): - line 130: * TODO: Support idleTimeout as per Tcp. - line 173: * TODO: Support idleTimeout as per Tcp. - line 200: * TODO: Support idleTimeout as per Tcp. unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala (3 lines): - line 96: * TODO: Support idleTimeout as per Tcp. - line 123: * TODO: Support idleTimeout as per Tcp. - line 155: * TODO: Support idleTimeout as per Tcp. slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala (2 lines): - line 75: toStatement: JFunction[T, String] // TODO: or use the pekko japi Function2 interface? - line 268: toStatement: JFunction[T, String] // TODO: or use the pekko japi Function2 interface? google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala (2 lines): - line 73: // TODO uptake any fix suggested for https://contributors.scala-lang.org/t/better-type-inference-for-scala-send-us-your-problematic-cases/2410/183 - line 103: // TODO uptake any fix suggested for https://contributors.scala-lang.org/t/better-type-inference-for-scala-send-us-your-problematic-cases/2410/183 unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala (1 line): - line 312: isInputShutdown = false) // FIXME: No need for the costly allocation of direct buffers yet given https://github.com/jnr/jnr-unixsocket/pull/49 s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1 line): - line 659: // TODO can we take in a Source[ByteString, NotUsed] without forcing chunking google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala (1 line): - line 63: parseNone(c) // TODO Once credentials are guaranteed to be managed centrally we can throw an error instead project/Dependencies.scala (1 line): - line 473: "org.springframework.boot" % "spring-boot-autoconfigure" % SpringBootVersion, // TODO should this be provided? couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala (1 line): - line 126: // FIXME verify cancellation works build.sbt (1 line): - line 228: // FIXME only generate the server for the tests again file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala (1 line): - line 252: // TODO the buffer content doesn't need to be kept elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ReadResult.scala (1 line): - line 49: // TODO include source: AnyVal in hashcode project/TestChanged.scala (1 line): - line 28: // TODO could use jgit ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducer.scala (1 line): - line 46: // TODO Not sure about parallelism, as the commits should not be in-order, maybe add it as parameter?