~singpolyma/sgx-jmp

ref: 3a0f5bf8c8866793ffdc1c5762904f72b294d4f2 sgx-jmp/lib/em.rb -rw-r--r-- 431 bytes
3a0f5bf8Stephen Paul Weber Helper to allow using sync-style code in a Promise context 1 year, 6 months ago
                                                                                
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
# frozen_string_literal: true

require "em_promise"

module EM
	def self.promise_defer(klass: EMPromise, &block)
		promise = klass.new
		EventMachine.defer(
			block,
			promise.method(:fulfill),
			promise.method(:reject)
		)
		promise
	end

	def self.promise_fiber
		promise = EMPromise.new
		Fiber.new {
			begin
				promise.fulfill(yield)
			rescue StandardError => e
				promise.reject(e)
			end
		}.resume
		promise
	end
end