Skip to content

Instantly share code, notes, and snippets.

View tylertreat's full-sized avatar

Tyler Treat tylertreat

972 followers · 49 following
View GitHub Profile
@tylertreat
tylertreat / iterator2.go
Created May 18, 2015 05:50
type IntContainer []int
func (i IntContainer) Iterator(cancel <-chan struct{}) <-chan int {
ch := make(chan int)
go func() {
for _, val := range i {
select {
case ch <- val:
case <-cancel:
close(ch)
@tylertreat
tylertreat / iterator.go
Created May 18, 2015 05:41
type IntContainer []int
func (i IntContainer) Iterator() <-chan int {
ch := make(chan int)
go func() {
for _, val := range i {
ch <- val
}
close(ch)
}()
@tylertreat
tylertreat / map_lookup.go
Last active August 29, 2015 14:21
intMap := make(map[string]int)
// Valid
value, ok := intMap["foo"]
println(value, ok)
// Also valid
value := intMap["foo"]
println(value)
@tylertreat
tylertreat / mangos_race.txt
Created January 15, 2015 01:21
go test -race github.com/gdamore/mangos/test
--- FAIL: TestBusTLS (1.00s)
common_test.go:500: Address tls+tcp://127.0.0.1:43934, 5 Cases
common_test.go:149: Jan 14 19:17:27.210: Id 0: Got dup START from 1
common_test.go:149: Jan 14 19:17:27.382: Id 0: Got dup START from 1
common_test.go:149: Jan 14 19:17:27.382: Id 0: Got dup START from 2
common_test.go:149: Jan 14 19:17:27.473: Id 0: Sent all 7 messages
common_test.go:149: Jan 14 19:17:27.477: Id 4: Got all 7 messages
common_test.go:149: Jan 14 19:17:27.477: Id 3: Got all 7 messages
common_test.go:149: Jan 14 19:17:27.478: Id 2: Got all 7 messages
@tylertreat
tylertreat / mangos_service_discovery.go
Created January 10, 2015 22:52
survey, _ = surveyor.NewSocket()
survey.AddTransport(tcp.NewTransport())
survey.Listen("tcp://:8000")
survey.SetOption(mangos.OptionSurveyTime, time.Second)
for {
survey.Send("Is anybody out there?")
for {
if msg, err = survey.Recv(); err != nil {
break
@tylertreat
tylertreat / mangos_example.go
Last active March 6, 2017 02:28
package main
import (
"fmt"
"os"
"time"
"github.com/gdamore/mangos"
"github.com/gdamore/mangos/protocol/pub"
"github.com/gdamore/mangos/protocol/sub"
"github.com/gdamore/mangos/transport/ipc"
@tylertreat
tylertreat / InfinitumIdentityMap.java
Created December 31, 2014 21:39
public <T> T createFromCursor(Cursor cursor, Class<T> modelClass) throws ModelConfigurationException, InfinitumRuntimeException {
return createFromCursorRec(cursor, modelClass);
}
@SuppressWarnings("unchecked")
private <T> T createFromCursorRec(Cursor cursor, Class<T> modelClass) throws ModelConfigurationException, InfinitumRuntimeException {
SqliteResult result = new SqliteResult(cursor);
T ret = (T) mClassReflector.getClassInstance(modelClass);
List<Field> fields = mPersistencePolicy.getPersistentFields(modelClass);
for (Field field : fields) {
@tylertreat
tylertreat / RefIntegrity.java
Created December 31, 2014 21:38
bill.getDepartment().setName("Bill's Department");
String dept = frank.getDepartment().getName(); // Should yield "Bill's Department" but doesn't
@tylertreat
tylertreat / ModelHash.java
Created December 31, 2014 21:38
public int computeModelHash(Class<?> c, Serializable pk) {
final int PRIME = 31;
int hash = 7;
hash *= PRIME + c.hashCode();
hash *= PRIME + pk.hashCode();
return hash;
}
@tylertreat
tylertreat / EntityMap.java
Created December 31, 2014 21:38
Map<Integer, Object> entities = new HashMap<Integer, Object>();