CHANGELOG.md | 100644 | 0 | 0 | | | 21.6 KB | 419103e1658ab6dac4d72f9ae7021520806a5121211af74062f2f1667a01d2c6 |
LICENSE.md | 100644 | 0 | 0 | | | 1.15 KB | 929c49e71d18b942fa02c2238b5824f9e7ee2443bfd5c6965926344154c9c61b |
README.md | 100644 | 0 | 0 | | | 18 KB | 31357e9360cf8acc33def2006832516b2c3ded90e5fd87b05d770951b92605e4 |
lib-edge/concurrent-edge.rb | 100644 | 0 | 0 | | | 349 Bytes | 30d256b3f4d5209691278338887dce01cc049548eddede8007b24a89f326a90e |
lib-edge/concurrent/actor.rb | 100644 | 0 | 0 | | | 3.6 KB | d7c6348f37d6feb4a48f57379a99be84d36bc40f76d3c62b6a8f2316ccd01a0d |
lib-edge/concurrent/actor/behaviour.rb | 100644 | 0 | 0 | | | 4.06 KB | cda467efd338edfb5c7486c8b2b889b66c828f41f4bb577ba1e1ba5408746df6 |
lib-edge/concurrent/actor/behaviour/abstract.rb | 100644 | 0 | 0 | | | 1.39 KB | 74fa95e53125756c6e54aca504cad5fad5b4da63d8957d52278cb896f4bc5d6f |
lib-edge/concurrent/actor/behaviour/awaits.rb | 100644 | 0 | 0 | | | 497 Bytes | 1d2051c61cd9faf8f2006c2183adcfe97033432d835c86289f024782b47f3967 |
lib-edge/concurrent/actor/behaviour/buffer.rb | 100644 | 0 | 0 | | | 1.95 KB | 2dab29545a373f25392d468f7a5f4e5630e1cd3e6ff891e3fa8fb00ab12934f0 |
lib-edge/concurrent/actor/behaviour/errors_on_unknown_message.rb | 100644 | 0 | 0 | | | 296 Bytes | ff4dcfb0aa3bd7d39794f19d8cfbb07316a45994044fefbcd025ad40aa780c3c |
lib-edge/concurrent/actor/behaviour/executes_context.rb | 100644 | 0 | 0 | | | 388 Bytes | 75957fb69391e67b2922d56b5570e6d06178d04646a41fa7dc84cb90dc81c510 |
lib-edge/concurrent/actor/behaviour/linking.rb | 100644 | 0 | 0 | | | 2.6 KB | 4929b86f154ab012898b25ac2e0e9650a38f82d18e13ade4d7bf07ed46b3de54 |
lib-edge/concurrent/actor/behaviour/pausing.rb | 100644 | 0 | 0 | | | 2.68 KB | da2e3c145270426456151ce45d013edce1327af6ac7f6f4cf2509f148c19d582 |
lib-edge/concurrent/actor/behaviour/removes_child.rb | 100644 | 0 | 0 | | | 349 Bytes | 9a7fa1c6ef4de709ef4a34283c47a7032959d8f3f626594783955457277b55aa |
lib-edge/concurrent/actor/behaviour/sets_results.rb | 100644 | 0 | 0 | | | 1.1 KB | 0530b72fdc2085a3a53d406dcf5e40a3e5ae90e86c35115b193733efad136c2e |
lib-edge/concurrent/actor/behaviour/supervising.rb | 100644 | 0 | 0 | | | 1.41 KB | c4ff6dc1ca1e34baf6669aa97c1b0cd4e0102b298805e9cc62ad9d0edad01009 |
lib-edge/concurrent/actor/behaviour/termination.rb | 100644 | 0 | 0 | | | 2.78 KB | abcfa550bee81a23ddb909aed75d031a83fc1a29c1ae43f4d72e8ab1ef3555f3 |
lib-edge/concurrent/actor/context.rb | 100644 | 0 | 0 | | | 5.41 KB | e0943591ccf6b6283945594654e3a7f01bf518c0caf5a1b93f691f2890311870 |
lib-edge/concurrent/actor/core.rb | 100644 | 0 | 0 | | | 7.74 KB | 92e42d7495ded95e37c069608a62cb8137d3b316299285951d3c9bdb18ff3c32 |
lib-edge/concurrent/actor/default_dead_letter_handler.rb | 100644 | 0 | 0 | | | 212 Bytes | a1d01bb3d01570980f809d944d70eb0b265d7244380f893a8f94b810c861977c |
lib-edge/concurrent/actor/envelope.rb | 100644 | 0 | 0 | | | 1.06 KB | 4d017131629b59f5305fc0fa0e819094407bde59e24f343c66b93627bb736029 |
lib-edge/concurrent/actor/errors.rb | 100644 | 0 | 0 | | | 552 Bytes | 557707cdad19984c72948c470331f4d2e17d0c2b67ddc676c8db92510d22a1a4 |
lib-edge/concurrent/actor/internal_delegations.rb | 100644 | 0 | 0 | | | 1.34 KB | a59b9c551ce2fc3374b0096038851d3df489ae0da635a1b709e56b65cf587b93 |
lib-edge/concurrent/actor/public_delegations.rb | 100644 | 0 | 0 | | | 684 Bytes | f63443fe3cde56712008db93e9c67e076ea39b9a4f541ebad18f5e556e0e4662 |
lib-edge/concurrent/actor/reference.rb | 100644 | 0 | 0 | | | 4.12 KB | 67248442205192356bc519fc162f06f03ecfa551bac48617b641eab7ef4cbcfc |
lib-edge/concurrent/actor/root.rb | 100644 | 0 | 0 | | | 1.03 KB | 6ed79bbb7ec5f47afd0fe96a6108babd9883dfde994a25cb5d4fd5ba211fb0a2 |
lib-edge/concurrent/actor/type_check.rb | 100644 | 0 | 0 | | | 1.04 KB | 7ccc7150554d1c35d1bc54bbb07d9c206232d46ee472299c37b10c7a60f5bf49 |
lib-edge/concurrent/actor/utils.rb | 100644 | 0 | 0 | | | 255 Bytes | d6c4fb81ac184278ed3a581bc97df3cc3f72d558a0e5c95e19f2cdda731996c7 |
lib-edge/concurrent/actor/utils/ad_hoc.rb | 100644 | 0 | 0 | | | 654 Bytes | f3f5ffa34184319f1fca4e9630dc2ba459fae8e03d5401b361df9cb40e9c6d47 |
lib-edge/concurrent/actor/utils/balancer.rb | 100644 | 0 | 0 | | | 1.15 KB | 836b8d2dca7cb4b285c635ccd7632a43561c4bfa2d3d8f18742597405d25badf |
lib-edge/concurrent/actor/utils/broadcast.rb | 100644 | 0 | 0 | | | 1.24 KB | 0ebd386309add148dfd7e645a45a21d764a126fcade2e6866cb38e1dd45544f8 |
lib-edge/concurrent/actor/utils/pool.rb | 100644 | 0 | 0 | | | 2.09 KB | 167af247162d992f32c5e4bede6fffc34573cb640d7e2ec91d626044c9e05b61 |
lib-edge/concurrent/channel.rb | 100644 | 0 | 0 | | | 6.52 KB | b7ae0bd768a7a69e3e1dc9e503f5214b42f634761b194c2b9a1d123df596de10 |
lib-edge/concurrent/channel/buffer.rb | 100644 | 0 | 0 | | | 309 Bytes | 9d95908aa2241a5cf3c2ca02e11f670593ad65614e46d096d72cf9cb04b6f446 |
lib-edge/concurrent/channel/buffer/base.rb | 100644 | 0 | 0 | | | 7.97 KB | b999edbac042d72c5bd074d1d4f8bcc1dc58b06d00543b83980c1d2fdf5294b6 |
lib-edge/concurrent/channel/buffer/buffered.rb | 100644 | 0 | 0 | | | 2.96 KB | 1deabcc7194738df0dd298c33fad9ce7bcfbb80a04778b71b7a2b1b5af969c6f |
lib-edge/concurrent/channel/buffer/dropping.rb | 100644 | 0 | 0 | | | 1.47 KB | bfeee534571e1895b87035d7fd60458c16ab4ea731a6b4ae6b9f8c53052ec69f |
lib-edge/concurrent/channel/buffer/sliding.rb | 100644 | 0 | 0 | | | 1.53 KB | 4296f32e801a495538c6382fa7b40008788359839d0acab9ff64eb4025a4f6d7 |
lib-edge/concurrent/channel/buffer/ticker.rb | 100644 | 0 | 0 | | | 861 Bytes | b601edcff53ead795a6b334c806d1a104cfe5254fdab85d682961e41ef4e59ca |
lib-edge/concurrent/channel/buffer/timer.rb | 100644 | 0 | 0 | | | 1.5 KB | b14ca09f4c311672fddfec663d21f48de7984644a1295b859a9dcf1c3f478981 |
lib-edge/concurrent/channel/buffer/unbuffered.rb | 100644 | 0 | 0 | | | 5.02 KB | e5766339f4ed8c762ac73304b3f4dc6ca2516bb5b6524c03a47553554d5c59b4 |
lib-edge/concurrent/channel/selector.rb | 100644 | 0 | 0 | | | 2.01 KB | d0d3442acb0cad248faee19f569bfd07c3a0db40401e78b58b4c50626e58e8a9 |
lib-edge/concurrent/channel/selector/after_clause.rb | 100644 | 0 | 0 | | | 634 Bytes | 3af90fa4f4122fb63cda0041cb634164f8412128b9a18ce8b1aaaa72de318f6c |
lib-edge/concurrent/channel/selector/default_clause.rb | 100644 | 0 | 0 | | | 283 Bytes | d66f05fc0daba94563aa0cc818cf20fa822518f196db7f1f6ceb4a891be8c0da |
lib-edge/concurrent/channel/selector/error_clause.rb | 100644 | 0 | 0 | | | 327 Bytes | b5c7a25d55feae7c5fb7959e2dc32120dacfe320ded2010d69ed2fd44da6e0e3 |
lib-edge/concurrent/channel/selector/put_clause.rb | 100644 | 0 | 0 | | | 512 Bytes | c7c3c41ef25642e99111d9f23ac0c4e1bb83c42d56ca8196f17a05d51dda42f2 |
lib-edge/concurrent/channel/selector/take_clause.rb | 100644 | 0 | 0 | | | 446 Bytes | 851f8d6f8065cf58862d3b681d7e2c2987d1d64c6c25db8c0940f0eaafe573ff |
lib-edge/concurrent/channel/tick.rb | 100644 | 0 | 0 | | | 1.29 KB | 4df7e08ef9ff1f5f7ac205c29c59126101c3e687a20383cacd7922c29b35caab |
lib-edge/concurrent/edge.rb | 100644 | 0 | 0 | | | 900 Bytes | 99d19e40aa5814c0aee729d878fff75bc10089bb52ed3f8cb25960351653a418 |
lib-edge/concurrent/edge/cancellation.rb | 100644 | 0 | 0 | | | 4.37 KB | ebb6def8baefac496ee893fc724d55443bd1a6853f7c35eb43a1582fee3278cf |
lib-edge/concurrent/edge/lock_free_linked_set.rb | 100644 | 0 | 0 | | | 4.71 KB | 05ecc00afbce38c1f5392507f5ea629e831c48e8d520d5819aab44ed27c2ee75 |
lib-edge/concurrent/edge/lock_free_linked_set/node.rb | 100644 | 0 | 0 | | | 2.21 KB | a1e5227cc977840a8ea1ebbcc2dae41e1a547c9787631b75c451de8bf5a00231 |
lib-edge/concurrent/edge/lock_free_linked_set/window.rb | 100644 | 0 | 0 | | | 1.43 KB | 32adb64a2929c2425145511516bbb840358e6f00713a22a09af440ad6f326e50 |
lib-edge/concurrent/edge/lock_free_queue.rb | 100644 | 0 | 0 | | | 3.41 KB | 586f06ac79a4026ddf8a6c6985c379e3aadb5dcdba1543fbd8ca90e11d3a1083 |
lib-edge/concurrent/edge/old_channel_integration.rb | 100644 | 0 | 0 | | | 1.26 KB | e701abc566cdb9d84c14887abd866b97dfab025015a9476b6c0d3ae8e2efedb5 |
lib-edge/concurrent/edge/processing_actor.rb | 100644 | 0 | 0 | | | 6.47 KB | b3233edfd449280b95085dfa702e971fdd41a3970380031ac64382a950b14481 |
lib-edge/concurrent/edge/promises.rb | 100644 | 0 | 0 | | | 6.17 KB | 466085780390ab0d7f5bbb8eea83474d2f5e10136e6dc495ad37a1a8fccadde9 |
lib-edge/concurrent/edge/throttle.rb | 100644 | 0 | 0 | | | 6.25 KB | cd3a11daf38f0935ddcde56fd51e595f0f8e6307022fa8cd86b9e6751f806f13 |
lib-edge/concurrent/lazy_register.rb | 100644 | 0 | 0 | | | 2.35 KB | 9186c93053608f6c562c57089c7548b2987164f15b5cf12df851753efe90ed53 |