CHANGELOG.md | 100644 | 0 | 0 | | | 26.9 KB | 948dd4770807088c9774f3e82c608d90aee5c56c820c5565aaa49d31f95e7216 |
LICENSE.txt | 100644 | 0 | 0 | | | 1.11 KB | c700bdb2093a4993b871cc5604820d0cfb2f6e69aa8f0e758f10148fe8809b3f |
README.md | 100644 | 0 | 0 | | | 21.4 KB | 2f4bb191205a25f5d100c2875d07f6a84a3a60c0180946dadb9e0efc2d441534 |
lib/concurrent-ruby-edge/concurrent-edge.rb | 100644 | 0 | 0 | | | 505 Bytes | 9c56a2f760dec476f9817dcfe55f69e1164a0aafb48e6b281e30037d94c346fb |
lib/concurrent-ruby-edge/concurrent/actor.rb | 100644 | 0 | 0 | | | 3.63 KB | a48607adb7e111ddf145e1aae7c1b8f131fa1b6df2526495a720d2d22f68e4cd |
lib/concurrent-ruby-edge/concurrent/actor/behaviour.rb | 100644 | 0 | 0 | | | 4.06 KB | cda467efd338edfb5c7486c8b2b889b66c828f41f4bb577ba1e1ba5408746df6 |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/abstract.rb | 100644 | 0 | 0 | | | 1.48 KB | e1f41536a1d47b222860c7c0bce4c7b6ea1aa4bfcb94c3f049bb9f7f99423d5c |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/awaits.rb | 100644 | 0 | 0 | | | 544 Bytes | 13370998aa7a624d50c46b2af877b08e938aad7e434fa5bd054e8125b7b3fb55 |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/buffer.rb | 100644 | 0 | 0 | | | 1.99 KB | 58d503987a9f376ff4859efdc23918bd3b0fc5a5b5d5ab7532928e19c6a4518e |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/errors_on_unknown_message.rb | 100644 | 0 | 0 | | | 343 Bytes | a0e60c4b5242bb9726d542b5fb2200c2db59e404ad4fdcdddbfd08b23df8f0b6 |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/executes_context.rb | 100644 | 0 | 0 | | | 435 Bytes | da00dc8ed81f33730d67cd2ad6098e705e269cabb0d80f04923bfbd78871fcf4 |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/linking.rb | 100644 | 0 | 0 | | | 2.64 KB | 091bc5a6ad8617bd7f38f29627327941b440a86b07d6e7d903410744be33596d |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/pausing.rb | 100644 | 0 | 0 | | | 2.72 KB | 57ca6add757fb9fc1f94a94e6748e07c5a89a28262c5b015590304c1d6d9d9fc |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/removes_child.rb | 100644 | 0 | 0 | | | 396 Bytes | d66dc817883ba880890cd3c6c5d560d9bf06653ac1d9c71f82e0514647a6972b |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/sets_results.rb | 100644 | 0 | 0 | | | 1.14 KB | 1def827add7f828ae10bf5cabb503ea80b3f1050167fa5d78a98e200ee1c552d |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/supervising.rb | 100644 | 0 | 0 | | | 1.45 KB | 613c7510abcad28acf98ed9c0c03736e047edd8f10a2f482672b3c38dd161455 |
lib/concurrent-ruby-edge/concurrent/actor/behaviour/termination.rb | 100644 | 0 | 0 | | | 2.82 KB | 86acfbeec084af8bc874b31ce0db0b11e10f38edd33e4ba51294080fd8acf195 |
lib/concurrent-ruby-edge/concurrent/actor/context.rb | 100644 | 0 | 0 | | | 5.48 KB | 77556d015a320057ed96f9fffbb8d1195f5a8118b1477be8aaf5ded5682d8b82 |
lib/concurrent-ruby-edge/concurrent/actor/core.rb | 100644 | 0 | 0 | | | 7.82 KB | d6bbd0c0e9551277a994edefb83a657fafe7dec978dd6b99aff48ca52dfa5d16 |
lib/concurrent-ruby-edge/concurrent/actor/default_dead_letter_handler.rb | 100644 | 0 | 0 | | | 248 Bytes | 2f25d8a6d4d588e0911557773ac1a9687b96d5e890e1010db909aa2a17019831 |
lib/concurrent-ruby-edge/concurrent/actor/envelope.rb | 100644 | 0 | 0 | | | 1.09 KB | fdf9dbc1bc2fdbf6a38b3f7c4c21de0109eb41e24bae60225dbb7aa5f7a6bfe6 |
lib/concurrent-ruby-edge/concurrent/actor/errors.rb | 100644 | 0 | 0 | | | 591 Bytes | 1c9c3738c7493b4f72bf9a0d3e1bf158893d9225dbfe34552864b907901e06c5 |
lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb | 100644 | 0 | 0 | | | 1.43 KB | 2e562fa4525ff614bb45b9d9128e82646562687a375d3d289f1ace8914b6f164 |
lib/concurrent-ruby-edge/concurrent/actor/public_delegations.rb | 100644 | 0 | 0 | | | 684 Bytes | f63443fe3cde56712008db93e9c67e076ea39b9a4f541ebad18f5e556e0e4662 |
lib/concurrent-ruby-edge/concurrent/actor/reference.rb | 100644 | 0 | 0 | | | 3.95 KB | 87b9596e344654447706004d41884b18a5449c26d79797b6122113624d7bf7b3 |
lib/concurrent-ruby-edge/concurrent/actor/root.rb | 100644 | 0 | 0 | | | 1.1 KB | 7b13c0e05cc40fd55e655cc879795dfcaa4bc01bad2320cce1d3e2001f3251cc |
lib/concurrent-ruby-edge/concurrent/actor/type_check.rb | 100644 | 0 | 0 | | | 1.04 KB | 7ccc7150554d1c35d1bc54bbb07d9c206232d46ee472299c37b10c7a60f5bf49 |
lib/concurrent-ruby-edge/concurrent/actor/utils.rb | 100644 | 0 | 0 | | | 255 Bytes | d6c4fb81ac184278ed3a581bc97df3cc3f72d558a0e5c95e19f2cdda731996c7 |
lib/concurrent-ruby-edge/concurrent/actor/utils/ad_hoc.rb | 100644 | 0 | 0 | | | 690 Bytes | d77c229ee3396fd626daba1a92e60829481adb935080b806454c226a52599049 |
lib/concurrent-ruby-edge/concurrent/actor/utils/balancer.rb | 100644 | 0 | 0 | | | 1.18 KB | f77661867e03482fe50457a07ccad51d348e4546d62490aaf41b4eb8b3efface |
lib/concurrent-ruby-edge/concurrent/actor/utils/broadcast.rb | 100644 | 0 | 0 | | | 1.27 KB | fe094e6abda0e1c5aba6391873ddba0b97057b8b188fcad362b4357b82b7147c |
lib/concurrent-ruby-edge/concurrent/actor/utils/pool.rb | 100644 | 0 | 0 | | | 2.13 KB | e460fb63edfeab9b24993b6cca245fbcadd3528a8e49fa3a31ac0b366522c760 |
lib/concurrent-ruby-edge/concurrent/channel.rb | 100644 | 0 | 0 | | | 6.5 KB | 0eb956174af1c8d7c65aba4cc17e8e18a3440f1464523212106eb556d94dff86 |
lib/concurrent-ruby-edge/concurrent/channel/buffer.rb | 100644 | 0 | 0 | | | 309 Bytes | 9d95908aa2241a5cf3c2ca02e11f670593ad65614e46d096d72cf9cb04b6f446 |
lib/concurrent-ruby-edge/concurrent/channel/buffer/base.rb | 100644 | 0 | 0 | | | 7.97 KB | b999edbac042d72c5bd074d1d4f8bcc1dc58b06d00543b83980c1d2fdf5294b6 |
lib/concurrent-ruby-edge/concurrent/channel/buffer/buffered.rb | 100644 | 0 | 0 | | | 2.96 KB | 1deabcc7194738df0dd298c33fad9ce7bcfbb80a04778b71b7a2b1b5af969c6f |
lib/concurrent-ruby-edge/concurrent/channel/buffer/dropping.rb | 100644 | 0 | 0 | | | 1.51 KB | 1cc52617cb08bfa76425746ab9dfb71e48f71881a53317e0ed2711adf7f630bd |
lib/concurrent-ruby-edge/concurrent/channel/buffer/sliding.rb | 100644 | 0 | 0 | | | 1.58 KB | 34a1b71cf559d653e1fbad32079ace15ee3481cc07a6aa95ff915184b538411e |
lib/concurrent-ruby-edge/concurrent/channel/buffer/ticker.rb | 100644 | 0 | 0 | | | 861 Bytes | b601edcff53ead795a6b334c806d1a104cfe5254fdab85d682961e41ef4e59ca |
lib/concurrent-ruby-edge/concurrent/channel/buffer/timer.rb | 100644 | 0 | 0 | | | 1.5 KB | b14ca09f4c311672fddfec663d21f48de7984644a1295b859a9dcf1c3f478981 |
lib/concurrent-ruby-edge/concurrent/channel/buffer/unbuffered.rb | 100644 | 0 | 0 | | | 5.02 KB | e5766339f4ed8c762ac73304b3f4dc6ca2516bb5b6524c03a47553554d5c59b4 |
lib/concurrent-ruby-edge/concurrent/channel/selector.rb | 100644 | 0 | 0 | | | 2.01 KB | d0d3442acb0cad248faee19f569bfd07c3a0db40401e78b58b4c50626e58e8a9 |
lib/concurrent-ruby-edge/concurrent/channel/selector/after_clause.rb | 100644 | 0 | 0 | | | 634 Bytes | 3af90fa4f4122fb63cda0041cb634164f8412128b9a18ce8b1aaaa72de318f6c |
lib/concurrent-ruby-edge/concurrent/channel/selector/default_clause.rb | 100644 | 0 | 0 | | | 283 Bytes | d66f05fc0daba94563aa0cc818cf20fa822518f196db7f1f6ceb4a891be8c0da |
lib/concurrent-ruby-edge/concurrent/channel/selector/error_clause.rb | 100644 | 0 | 0 | | | 327 Bytes | b5c7a25d55feae7c5fb7959e2dc32120dacfe320ded2010d69ed2fd44da6e0e3 |
lib/concurrent-ruby-edge/concurrent/channel/selector/put_clause.rb | 100644 | 0 | 0 | | | 512 Bytes | c7c3c41ef25642e99111d9f23ac0c4e1bb83c42d56ca8196f17a05d51dda42f2 |
lib/concurrent-ruby-edge/concurrent/channel/selector/take_clause.rb | 100644 | 0 | 0 | | | 446 Bytes | 851f8d6f8065cf58862d3b681d7e2c2987d1d64c6c25db8c0940f0eaafe573ff |
lib/concurrent-ruby-edge/concurrent/channel/tick.rb | 100644 | 0 | 0 | | | 1.29 KB | f754803b27a1c2c5c321d046fbbb95447967db3817769a72165f1ebe167c69f6 |
lib/concurrent-ruby-edge/concurrent/edge.rb | 100644 | 0 | 0 | | | 900 Bytes | 99d19e40aa5814c0aee729d878fff75bc10089bb52ed3f8cb25960351653a418 |
lib/concurrent-ruby-edge/concurrent/edge/cancellation.rb | 100644 | 0 | 0 | | | 3.66 KB | bde0758720b632f276269a9161fd690d27204094ed96449d0df7eed284e20d18 |
lib/concurrent-ruby-edge/concurrent/edge/channel.rb | 100644 | 0 | 0 | | | 16.3 KB | 298c5eae1fe94fb3719e56b580fdddb051827927a3b4960d162b3d4a4e078f06 |
lib/concurrent-ruby-edge/concurrent/edge/erlang_actor.rb | 100644 | 0 | 0 | | | 47.8 KB | 4bf7b657309fb3099d66afd83c81301ed06a9c647529b85594126113aeb21d26 |
lib/concurrent-ruby-edge/concurrent/edge/lock_free_linked_set.rb | 100644 | 0 | 0 | | | 4.71 KB | 05ecc00afbce38c1f5392507f5ea629e831c48e8d520d5819aab44ed27c2ee75 |
lib/concurrent-ruby-edge/concurrent/edge/lock_free_linked_set/node.rb | 100644 | 0 | 0 | | | 2.21 KB | a67a8f52e9509bd5659924aa855c9218134fe37002fdbca69a403957e34341b8 |
lib/concurrent-ruby-edge/concurrent/edge/lock_free_linked_set/window.rb | 100644 | 0 | 0 | | | 1.43 KB | 32adb64a2929c2425145511516bbb840358e6f00713a22a09af440ad6f326e50 |
lib/concurrent-ruby-edge/concurrent/edge/lock_free_queue.rb | 100644 | 0 | 0 | | | 3.45 KB | d00bdd98739418c43ec453985d0fd2032ae657b4242aa331f591c87ae11b332c |
lib/concurrent-ruby-edge/concurrent/edge/old_channel_integration.rb | 100644 | 0 | 0 | | | 1.29 KB | 0545ab0c45d64e0505966586b9eaf59d60d364082c44aab6dcd3aacfc7207e83 |
lib/concurrent-ruby-edge/concurrent/edge/processing_actor.rb | 100644 | 0 | 0 | | | 7.36 KB | 4a589d54538d616d8c01cd31363a4742a4ffc71d3673c5b3d5842edeee548e14 |
lib/concurrent-ruby-edge/concurrent/edge/promises.rb | 100644 | 0 | 0 | | | 5.67 KB | 67a986243f758ca3911ae11e5a16cdc30f586dc1a40dc3ca379221e79c69edbd |
lib/concurrent-ruby-edge/concurrent/edge/throttle.rb | 100644 | 0 | 0 | | | 7 KB | a4157e10e30b1cb12c31a70a6340389df4f158f58db6128642bec4ab2837db92 |
lib/concurrent-ruby-edge/concurrent/edge/version.rb | 100644 | 0 | 0 | | | 47 Bytes | 599fa4e284e61f3cef9f17c959cf8dedfff9801217c78f7bfad2e0ec12e582de |
lib/concurrent-ruby-edge/concurrent/executor/wrapping_executor.rb | 100644 | 0 | 0 | | | 1.67 KB | 59baf24588d88b8e8e1e94b819168ffcc54eb368fd6d2b115f5c6cbfeb863b4d |
lib/concurrent-ruby-edge/concurrent/lazy_register.rb | 100644 | 0 | 0 | | | 2.35 KB | 9186c93053608f6c562c57089c7548b2987164f15b5cf12df851753efe90ed53 |