KumaChan/standalone/rx/mutable.go

package rx


type Mutable interface {
	Get() Observable
	Set(Object) Observable
	Update(func(Object)(Object)) Observable
}

type MutableImpl struct {
	value   Object
}
func CreateMutable(initial Object) Mutable {
	return &MutableImpl { initial }
}
func (c *MutableImpl) Get() Observable {
	return NewSync(func() (Object, bool) {
		return c.value, true
	})
}
func (c *MutableImpl) Set(new_val Object) Observable {
	return NewSync(func() (Object, bool) {
		c.value = new_val
		return nil, true
	})
}
func (c *MutableImpl) Update(f func(Object)(Object)) Observable {
	return NewSync(func() (Object, bool) {
		c.value = f(c.value)
		return nil, true
	})
}

type StringHashMap  map[string] Object
func CreateStringHashMap(m map[string] Object) StringHashMap {
	return StringHashMap(m)
}
func (m StringHashMap) Has(key string) Observable {
	return NewSync(func()(Object, bool) {
		var _, exists = m[key]
		return exists, true
	})
}
func (m StringHashMap) Get(key string) Observable {
	return NewSync(func()(Object, bool) {
		var val, exists = m[key]
		if exists {
			return Optional { true, val }, true
		} else {
			return Optional {}, true
		}
	})
}
func (m StringHashMap) Set(key string, val Object) Observable {
	return NewSync(func()(Object, bool) {
		m[key] = val
		return nil, true
	})
}
func (m StringHashMap) Delete(key string) Observable {
	return NewSync(func()(Object, bool) {
		var deleted, exists = m[key]
		if exists {
			delete(m, key)
			return Optional { true, deleted }, true
		} else {
			return Optional {}, true
		}
	})
}

type NumberHashMap  map[uint] Object
func CreateNumberHashMap(m map[uint] Object) NumberHashMap {
	return NumberHashMap(m)
}
func (m NumberHashMap) Has(key uint) Observable {
	return NewSync(func()(Object, bool) {
		var _, exists = m[key]
		return exists, true
	})
}
func (m NumberHashMap) Get(key uint) Observable {
	return NewSync(func()(Object, bool) {
		var val, exists = m[key]
		if exists {
			return Optional { true, val }, true
		} else {
			return Optional {}, true
		}
	})
}
func (m NumberHashMap) Set(key uint, val Object) Observable {
	return NewSync(func()(Object, bool) {
		m[key] = val
		return nil, true
	})
}
func (m NumberHashMap) Delete(key uint) Observable {
	return NewSync(func()(Object, bool) {
		var deleted, exists = m[key]
		if exists {
			delete(m, key)
			return Optional { true, deleted }, true
		} else {
			return Optional {}, true
		}
	})
}

type Buffer struct {
	data  *([] byte)
}
func CreateBuffer(capacity uint) Buffer {
	var data = make([] byte, 0, capacity)
	return Buffer { &data }
}
func (buf Buffer) Write(bytes ([] byte)) Observable {
	return NewSync(func() (Object, bool) {
		*buf.data = append(*buf.data, bytes...)
		return nil, true
	})
}
func (buf Buffer) Dump() Observable {
	return NewGoroutine(func(sender Sender) {
		var dumped = make([] byte, len(*buf.data))
		copy(dumped, *buf.data)
		sender.Next(dumped)
		sender.Complete()
	})
}