raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11
9762 commits 1 branch 31 tags 268 MiB
Commit graph

9762 commits

This branch
This branch
All branches
Author SHA1 Message Date
Oliver Schulz
844f09a5c7 Added methods getByte, getShort, etc. to ByteIterator 2012-05-18 01:09:01 +02:00
Oliver Schulz
15507dff85 Added methods putByte, putShort, etc. to ByteStringBuilder 2012-05-18 01:09:01 +02:00
Oliver Schulz
f4ee17dcac Added methods getBytes, getShorts, etc. to ByteIterator 2012-05-18 01:09:01 +02:00
Oliver Schulz
f127b50ca2 Added methods putBytes, putShorts, etc. to ByteStringBuilder 2012-05-18 01:09:01 +02:00
Oliver Schulz
4517b44e8b Added a java.io.InputStream wrapper for ByteIterator. 2012-05-18 01:09:01 +02:00
Oliver Schulz
53a01ecc12 Added a java.io.OutputStream wrapper to ByteStringBuilder 2012-05-18 01:09:01 +02:00
Oliver Schulz
3263f43060 Added a companion object, length and sizeHint to class ByteStreamBuilder 2012-05-18 01:09:01 +02:00
Oliver Schulz
b7e2246ce8 Improved implementations of ByteIterator.++ 2012-05-18 01:09:01 +02:00
Oliver Schulz
018f1c92d5 Improved implementations of ByteString.++ 2012-05-18 01:09:00 +02:00
Oliver Schulz
c8d7c995db Enhanced ByteString implementation using ByteIterator 2012-05-18 01:09:00 +02:00
Oliver Schulz
76dab6354e Added ByteIterator 2012-05-18 01:09:00 +02:00
Oliver Schulz
3436c3b14d Added ByteString1.apply(bytes, startIndex, length) 2012-05-18 01:09:00 +02:00
Oliver Schulz
322edb2eca Introduced ContByteString to complement CompactByteString 
Many operations are necessarily more efficient on contiguous data
(represented by a contiguous part of an array) than on chunked data
(e.g. wrapping in a ByteBuffer, etc.).

It should be possibly to check whether a ByteString fulfills this
requirement and to specifically request such a ByteString for specific
applications. The new abstract ContByteString, as a natural bridge
between CompactByteString and ByteString, provides this.
 2012-05-18 01:09:00 +02:00
Oliver Schulz
9076fbf268 Optimized ByteString1.++ 2012-05-18 01:09:00 +02:00
Roland
4256522fc8 clarify semantics of name reuse/gracefulStop, see #2073 2012-05-16 13:43:00 +02:00
Roland
3757fbd24b Merge branch 'wip-expect-primitives-∂π' 2012-05-16 09:10:58 +02:00
Roland
9105720809 properly take boxing into account when expecting messages by type or class 2012-05-15 21:12:46 +02:00
viktorklang
4794220e55 Merge pull request #454 from srp/master 
assorted IO.SocketOption changes from last pull request comments
 2012-05-15 07:19:04 -07:00
Scott R. Parish
39a36b7116 IO.SocketOption: switch back to one line-per case 2012-05-15 09:10:19 -05:00
Scott R. Parish
4eef9cd341 IO#fowardFailure: catch NonFatal rather then all Throwables 2012-05-15 09:10:19 -05:00
Scott R. Parish
8aeb313492 IO: use defaults for SocketOption param rather then overloading 
Now that we're not targetting a 2.0 release we can break backwards
binary compat.
 2012-05-15 08:49:57 -05:00
Scott R. Parish
34b2c24d33 IO.SocketOption: catch exceptions and forward them back to sender 2012-05-15 08:40:03 -05:00
Scott R. Parish
f7e1fbc11b IO.SocketOption: add require around TrafficClass range restrictions 2012-05-15 07:33:09 -05:00
Scott R. Parish
ecf8469c75 IO.SocketOption: improve SoTimeout documentation wording 2012-05-15 07:32:29 -05:00
Scott R. Parish
802f18b46b IO.SocketOption to link to java docs 
Unfortunately scaladocs don't seem to support urls, or i would make
these link directly to the Socket docs
 2012-05-15 07:20:08 -05:00
Jonas Bonér
2e248e4b49 Removed code for tutorial, already removed in docs since duplicate in Typesafe/Akka getting started guide and template 2012-05-15 09:19:02 +02:00
Jonas Bonér
1c426e4772 Improved the docs for dataflow concurrency 2012-05-14 15:43:58 +02:00
Viktor Klang
796a155223 Merge remote branch 'origin/wip-adding-assertions-in-IO-√' 2012-05-14 11:09:16 +02:00
viktorklang
4d9c836b04 Merge pull request #450 from akka/wip-checked-duration-∂π 
Wip checked duration ∂π
 2012-05-14 01:52:25 -07:00
patriknw
80cbb7e32b Merge pull request #451 from akka/wip-2065-AccrualFailureDetector-maxSampleSize-patriknw 
AccrualFailureDetector doesn't use maxSampleSize correctly. See #2065
 2012-05-14 01:42:21 -07:00
Patrik Nordwall
99d036d99a Use maxSampleSize correctly. See #2065 
* Added failing test
* Fixed wrong drop
* Boy scout cleanup
 2012-05-14 09:35:15 +02:00
Patrik Nordwall
bcc208819a Added .scalastyle to .gitignore 2012-05-14 09:34:59 +02:00
Roland
18566a7401 fix SchedulerSpec 2012-05-13 23:22:41 +02:00
Roland
71e1597987 add range checks (and tests) for Duration, see #2064 
- also improve hashCode and allow negative string representation
 2012-05-13 23:04:16 +02:00
Peter Vlugter
885ed7cb36 Use previous snapshot publishing, rather than sonatype 2012-05-13 21:14:23 +12:00
viktorklang
ca1baebfbb Merge pull request #448 from akka/ticket_1732 
various comments processed on top of ticket 1732
 2012-05-12 06:36:51 -07:00
RayRoestenburg
a142700294 named ActivationTracker actor camelActivationTracker 2012-05-11 21:46:40 +02:00
RayRoestenburg
d4c5867528 various comments processed 2012-05-11 21:37:40 +02:00
Björn Antonsson
d004240f33 Merge branch 'master' of github.com:akka/akka 2012-05-11 18:31:29 +02:00
Björn Antonsson
38d43aee13 Added caution about custom routers to docs 2012-05-11 18:31:20 +02:00
Viktor Klang
78a58361f1 Formatting of ActorComponent 2012-05-11 16:51:15 +02:00
viktorklang
8df7a30ca8 Merge pull request #278 from teamon/patch-2 
Fixed akka-docs/java/logging.rst debug configuration
 2012-05-11 07:28:03 -07:00
viktorklang
e9b9ba6f3c Merge pull request #432 from akka/ticket_1732 
ticket-1732, return Failure on producer ask _and_ throw AkkaCamelExcepti...
 2012-05-11 07:21:48 -07:00
Viktor Klang
0eb5c503f5 Changing to the correct gh id for me in the Publish.scala 2012-05-11 16:19:46 +02:00
viktorklang
fcc8f4cad6 Merge pull request #384 from jsuereth/feature/sonatype-publish 
Fixes for maven central publishing.
 2012-05-11 07:18:34 -07:00
viktorklang
2ac45a1404 Merge pull request #446 from akka/wip-removing-updaters-dispatcher-√ 
Removing the Atomic*Updaters from MessageDispatcher, switching to Unsafe...
 2012-05-11 07:10:06 -07:00
viktorklang
bb36ef1abe Merge pull request #447 from akka/wip-optimize-address-√ 
Removing 1 lazy field from Address
 2012-05-11 07:08:45 -07:00
Viktor Klang
db3ce87917 Removing the Atomic*Updaters from MessageDispatcher, switching to Unsafe all the way baby 2012-05-11 15:00:37 +02:00
Viktor Klang
1262ebe363 Adding assertions into the new great socket options from Scott 2012-05-11 14:59:41 +02:00
Viktor Klang
ac2acf7714 Removing 1 lazy field from Address 2012-05-11 14:58:34 +02:00